Skip to content

Commit

Permalink
Merge pull request moby#4 from progrium/volume_plugin_fixes
Browse files Browse the repository at this point in the history
Two fixes
  • Loading branch information
calavera committed May 8, 2015
2 parents 9e4b5e7 + 8ae6aab commit fe543e0
Show file tree
Hide file tree
Showing 2 changed files with 22 additions and 21 deletions.
1 change: 1 addition & 0 deletions volume/plugins/api.go
Expand Up @@ -16,6 +16,7 @@ func init() {
type VolumeDriver interface {
Create(name string) (err error)
Remove(name string) (err error)
Path(name string) (mountpoint string, err error)
Mount(name string) (mountpoint string, err error)
Unmount(name string) (err error)
}
42 changes: 21 additions & 21 deletions volume/plugins/proxy.go
Expand Up @@ -5,45 +5,45 @@ import plug "github.com/docker/docker/plugins"
// currently created by hand. generation tool would generate this like:
// $ rpc-gen volume/plugins/api.go VolumeDriver > volume/plugins/proxy.go

type VolumeDriverCreateArgs struct {
type volumeDriverCreateArgs struct {
Name string
}

type VolumeDriverCreateReturn struct {
type volumeDriverCreateReturn struct {
Err error
}

type VolumeDriverRemoveArgs struct {
type volumeDriverRemoveArgs struct {
Name string
}

type VolumeDriverRemoveReturn struct {
type volumeDriverRemoveReturn struct {
Err error
}

type VolumeDriverPathArgs struct {
type volumeDriverPathArgs struct {
Name string
}

type VolumeDriverPathReturn struct {
type volumeDriverPathReturn struct {
Mountpoint string
Err error
}

type VolumeDriverMountArgs struct {
type volumeDriverMountArgs struct {
Name string
}

type VolumeDriverMountReturn struct {
type volumeDriverMountReturn struct {
Mountpoint string
Err error
}

type VolumeDriverUnmountArgs struct {
type volumeDriverUnmountArgs struct {
Name string
}

type VolumeDriverUnmountReturn struct {
type volumeDriverUnmountReturn struct {
Err error
}

Expand All @@ -52,8 +52,8 @@ type volumeDriverProxy struct {
}

func (pp *volumeDriverProxy) Create(name string) error {
args := VolumeDriverCreateArgs{name}
var ret VolumeDriverCreateReturn
args := volumeDriverCreateArgs{name}
var ret volumeDriverCreateReturn
err := pp.client.Call("VolumeDriver.Create", args, &ret)
if err != nil {
return err
Expand All @@ -62,8 +62,8 @@ func (pp *volumeDriverProxy) Create(name string) error {
}

func (pp *volumeDriverProxy) Remove(name string) error {
args := VolumeDriverRemoveArgs{name}
var ret VolumeDriverRemoveReturn
args := volumeDriverRemoveArgs{name}
var ret volumeDriverRemoveReturn
err := pp.client.Call("VolumeDriver.Remove", args, &ret)
if err != nil {
return err
Expand All @@ -72,26 +72,26 @@ func (pp *volumeDriverProxy) Remove(name string) error {
}

func (pp *volumeDriverProxy) Path(name string) (string, error) {
args := VolumeDriverPathArgs{name}
var ret VolumeDriverPathReturn
args := volumeDriverPathArgs{name}
var ret volumeDriverPathReturn
if err := pp.client.Call("VolumeDriver.Path", args, &ret); err != nil {
return "", err
}
return ret.Mountpoint, ret.Err
}

func (pp *volumeDriverProxy) Mount(name string) (mountpoint string, err error) {
args := VolumeDriverMountArgs{name}
var ret VolumeDriverMountReturn
func (pp *volumeDriverProxy) Mount(name string) (string, error) {
args := volumeDriverMountArgs{name}
var ret volumeDriverMountReturn
if err = pp.client.Call("VolumeDriver.Mount", args, &ret); err != nil {
return "", err
}
return ret.Mountpoint, ret.Err
}

func (pp *volumeDriverProxy) Unmount(name string) error {
args := VolumeDriverUnmountArgs{name}
var ret VolumeDriverUnmountReturn
args := volumeDriverUnmountArgs{name}
var ret volumeDriverUnmountReturn
err := pp.client.Call("VolumeDriver.Unmount", args, &ret)
if err != nil {
return err
Expand Down

0 comments on commit fe543e0

Please sign in to comment.