1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
|
package shim
import (
"github.com/docker/docker/volume"
volumeplugin "github.com/docker/go-plugins-helpers/volume"
)
type shimDriver struct {
d volume.Driver
}
// NewHandlerFromVolumeDriver creates a plugin handler from an existing volume
// driver. This could be used, for instance, by the `local` volume driver built-in
// to Docker Engine and it would create a plugin from it that maps plugin API calls
// directly to any volume driver that satifies the volume.Driver interface from
// Docker Engine.
func NewHandlerFromVolumeDriver(d volume.Driver) *volumeplugin.Handler {
return volumeplugin.NewHandler(&shimDriver{d})
}
func (d *shimDriver) Create(req *volumeplugin.CreateRequest) error {
_, err := d.d.Create(req.Name, req.Options)
return err
}
func (d *shimDriver) List() (*volumeplugin.ListResponse, error) {
var res *volumeplugin.ListResponse
ls, err := d.d.List()
if err != nil {
return &volumeplugin.ListResponse{}, err
}
vols := make([]*volumeplugin.Volume, len(ls))
for i, v := range ls {
vol := &volumeplugin.Volume{
Name: v.Name(),
Mountpoint: v.Path(),
}
vols[i] = vol
}
res.Volumes = vols
return res, nil
}
func (d *shimDriver) Get(req *volumeplugin.GetRequest) (*volumeplugin.GetResponse, error) {
var res *volumeplugin.GetResponse
v, err := d.d.Get(req.Name)
if err != nil {
return &volumeplugin.GetResponse{}, err
}
res.Volume = &volumeplugin.Volume{
Name: v.Name(),
Mountpoint: v.Path(),
Status: v.Status(),
}
return &volumeplugin.GetResponse{}, nil
}
func (d *shimDriver) Remove(req *volumeplugin.RemoveRequest) error {
v, err := d.d.Get(req.Name)
if err != nil {
return err
}
if err := d.d.Remove(v); err != nil {
return err
}
return nil
}
func (d *shimDriver) Path(req *volumeplugin.PathRequest) (*volumeplugin.PathResponse, error) {
var res *volumeplugin.PathResponse
v, err := d.d.Get(req.Name)
if err != nil {
return &volumeplugin.PathResponse{}, err
}
res.Mountpoint = v.Path()
return res, nil
}
func (d *shimDriver) Mount(req *volumeplugin.MountRequest) (*volumeplugin.MountResponse, error) {
var res *volumeplugin.MountResponse
v, err := d.d.Get(req.Name)
if err != nil {
return &volumeplugin.MountResponse{}, err
}
pth, err := v.Mount(req.ID)
if err != nil {
return &volumeplugin.MountResponse{}, err
}
res.Mountpoint = pth
return res, nil
}
func (d *shimDriver) Unmount(req *volumeplugin.UnmountRequest) error {
v, err := d.d.Get(req.Name)
if err != nil {
return err
}
if err := v.Unmount(req.ID); err != nil {
return err
}
return nil
}
func (d *shimDriver) Capabilities() *volumeplugin.CapabilitiesResponse {
var res *volumeplugin.CapabilitiesResponse
res.Capabilities = volumeplugin.Capability{Scope: d.d.Scope()}
return res
}
|
