-
Notifications
You must be signed in to change notification settings - Fork 4
/
volume_create.go
52 lines (44 loc) · 1.46 KB
/
volume_create.go
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
package docker
import (
"context"
"strings"
"github.com/docker/docker/api/types/volume"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/status"
"github.com/openconfig/containerz/containers"
cpb "github.com/openconfig/gnoi/containerz"
)
// VolumeCreate creates a volume with the provided name using the driver specified. The driver
// default to LOCAL if it is not specified. The name is autogenerated by the target if it is empty.
func (m *Manager) VolumeCreate(ctx context.Context, name string, driver cpb.Driver, opts ...options.Option) (string, error) {
optionz := options.ApplyOptions(opts...)
kind := "local"
volOpts := map[string]string{}
switch driver {
case cpb.Driver_DS_UNSPECIFIED, cpb.Driver_DS_LOCAL:
kind = "local"
if optionz.VolumeDriverOptions != nil {
vopts, ok := optionz.VolumeDriverOptions.(*cpb.LocalDriverOptions)
if !ok {
return "", status.Error(codes.InvalidArgument, "driver is marked as local but options are not LocalDriverOptions")
}
switch vopts.GetType() {
case cpb.LocalDriverOptions_TYPE_UNSPECIFIED, cpb.LocalDriverOptions_TYPE_NONE:
volOpts["type"] = "none"
}
volOpts["o"] = strings.Join(vopts.GetOptions(), ",")
volOpts["device"] = vopts.GetMountpoint()
}
}
create := volume.CreateOptions{
Name: name,
Driver: kind,
Labels: optionz.VolumeLabels,
DriverOpts: volOpts,
}
v, err := m.client.VolumeCreate(ctx, create)
if err != nil {
return "", err
}
return v.Name, nil
}