-
Notifications
You must be signed in to change notification settings - Fork 1
/
volume.go
201 lines (158 loc) · 4.04 KB
/
volume.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
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
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
// Code generated by lesiw.io/ctrctl. DO NOT EDIT.
package ctrctl
import (
"fmt"
"os/exec"
)
type VolumeCreateOpts struct {
// Base exec.Cmd.
Cmd *exec.Cmd
// Cluster Volume availability (`active`, `pause`, `drain`).
Availability string
// Specify volume driver name.
Driver string
// Cluster Volume group (cluster volumes).
Group string
// Print usage.
Help bool
// Set metadata for a volume.
Label []string
// Minimum size of the Cluster Volume in bytes.
LimitBytes string
// Specify volume name.
Name string
// Set driver specific options.
Opt string
// Maximum size of the Cluster Volume in bytes.
RequiredBytes string
// Cluster Volume access scope (`single`, `multi`).
Scope string
// Cluster Volume secrets.
Secret string
// Cluster Volume access sharing (`none`, `readonly`, `onewriter`, `all`).
Sharing string
// A topology that the Cluster Volume would be preferred in.
TopologyPreferred []string
// A topology that the Cluster Volume must be accessible from.
TopologyRequired []string
// Cluster Volume access type (`mount`, `block`).
Type string
}
// Create a volume.
func VolumeCreate(opts *VolumeCreateOpts, volume string) (string, error) {
return runCtrCmd(
[]string{"volume", "create"},
[]string{volume},
opts,
0,
)
}
type VolumeInspectOpts struct {
// Base exec.Cmd.
Cmd *exec.Cmd
// Format output using a custom template:
// 'json': Print in JSON format.
// 'TEMPLATE': Print output using the given Go template.
// Refer to https://docs.docker.com/go/formatting/ for more information about formatting output with templates.
Format string
// Print usage.
Help bool
}
// Display detailed information on one or more volumes.
func VolumeInspect(opts *VolumeInspectOpts, volume ...string) (string, error) {
if len(volume) == 0 {
return "", fmt.Errorf("volume must have at least one value")
}
return runCtrCmd(
[]string{"volume", "inspect"},
volume,
opts,
0,
)
}
type VolumeLsOpts struct {
// Base exec.Cmd.
Cmd *exec.Cmd
// Display only cluster volumes, and use cluster volume list formatting.
Cluster bool
// Provide filter values (e.g. `dangling=true`).
Filter string
// Format output using a custom template:
// 'table': Print output in table format with column headers (default).
// 'table TEMPLATE': Print output in table format using the given Go template.
// 'json': Print in JSON format.
// 'TEMPLATE': Print output using the given Go template.
// Refer to https://docs.docker.com/go/formatting/ for more information about formatting output with templates.
Format string
// Print usage.
Help bool
// Only display volume names.
Quiet bool
}
// List volumes.
func VolumeLs(opts *VolumeLsOpts) (string, error) {
return runCtrCmd(
[]string{"volume", "ls"},
[]string{},
opts,
0,
)
}
type VolumePruneOpts struct {
// Base exec.Cmd.
Cmd *exec.Cmd
// Remove all unused volumes, not just anonymous ones.
All bool
// Provide filter values (e.g. `label=<label>`).
Filter string
// Do not prompt for confirmation.
Force bool
// Print usage.
Help bool
}
// Remove unused local volumes.
func VolumePrune(opts *VolumePruneOpts) (string, error) {
return runCtrCmd(
[]string{"volume", "prune"},
[]string{},
opts,
0,
)
}
type VolumeRmOpts struct {
// Base exec.Cmd.
Cmd *exec.Cmd
// Force the removal of one or more volumes.
Force bool
// Print usage.
Help bool
}
// Remove one or more volumes.
func VolumeRm(opts *VolumeRmOpts, volume ...string) (string, error) {
if len(volume) == 0 {
return "", fmt.Errorf("volume must have at least one value")
}
return runCtrCmd(
[]string{"volume", "rm"},
volume,
opts,
0,
)
}
type VolumeUpdateOpts struct {
// Base exec.Cmd.
Cmd *exec.Cmd
// Cluster Volume availability (`active`, `pause`, `drain`).
Availability string
// Print usage.
Help bool
}
// Update a volume (cluster volumes only).
func VolumeUpdate(opts *VolumeUpdateOpts, volume string) (string, error) {
return runCtrCmd(
[]string{"volume", "update"},
[]string{volume},
opts,
0,
)
}