forked from rexray/rexray
-
Notifications
You must be signed in to change notification settings - Fork 0
/
drivers_volume.go
205 lines (172 loc) · 5.55 KB
/
drivers_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
202
203
204
205
package core
import (
"bytes"
"github.com/emccode/rexray/core/errors"
)
// VolumeOpts is a map of options used when creating a new volume
type VolumeOpts map[string]string
// VolumeDriver is the interface implemented by types that provide volume
// introspection and management.
type VolumeDriver interface {
Driver
// Mount will return a mount point path when specifying either a volumeName
// or volumeID. If a overwriteFs boolean is specified it will overwrite
// the FS based on newFsType if it is detected that there is no FS present.
Mount(
volumeName, volumeID string,
overwriteFs bool, newFsType string, preempt bool) (string, error)
// Unmount will unmount the specified volume by volumeName or volumeID.
Unmount(volumeName, volumeID string) error
// Path will return the mounted path of the volumeName or volumeID.
Path(volumeName, volumeID string) (string, error)
// Create will create a new volume with the volumeName and opts.
Create(volumeName string, opts VolumeOpts) error
// Remove will remove a volume of volumeName.
Remove(volumeName string) error
// Attach will attach a volume based on volumeName to the instance of
// instanceID.
Attach(volumeName, instanceID string, force bool) (string, error)
// Detach will detach a volume based on volumeName to the instance of
// instanceID.
Detach(volumeName, instanceID string, force bool) error
// NetworkName will return an identifier of a volume that is relevant when
// corelating a local device to a device that is the volumeName to the
// local instanceID.
NetworkName(volumeName, instanceID string) (string, error)
}
// VolumeDriverManager acts as both a VolumeDriver and as an aggregate of
// volume drivers, providing batch methods.
type VolumeDriverManager interface {
VolumeDriver
// Drivers gets a channel which receives a list of all of the configured
// volume drivers.
Drivers() <-chan VolumeDriver
// UnmountAll unmounts all volumes.
UnmountAll() error
// RemoveAll removes all volumes.
RemoveAll() error
// DetachAll detaches all volumes attached to the instance of instanceID.
DetachAll(instanceID string) error
}
type vdm struct {
rexray *RexRay
drivers map[string]VolumeDriver
}
func (r *vdm) Init(rexray *RexRay) error {
if len(r.drivers) == 0 {
return errors.ErrNoVolumeDrivers
}
return nil
}
func (r *vdm) Name() string {
var b bytes.Buffer
for d := range r.Drivers() {
if b.Len() > 0 {
b.WriteString(" ")
}
b.WriteString(d.Name())
}
return b.String()
}
func (r *vdm) Drivers() <-chan VolumeDriver {
c := make(chan VolumeDriver)
go func() {
if len(r.drivers) == 0 {
close(c)
return
}
for _, v := range r.drivers {
c <- v
}
close(c)
}()
return c
}
// UnmountAll unmounts all volumes.
func (r *vdm) UnmountAll() error {
for range r.drivers {
return nil
}
return errors.ErrNoVolumesDetected
}
// RemoveAll removes all volumes.
func (r *vdm) RemoveAll() error {
for range r.drivers {
return nil
}
return errors.ErrNoVolumesDetected
}
// DetachAll detaches all volumes attached to the instance of instanceID.
func (r *vdm) DetachAll(instanceID string) error {
for range r.drivers {
return nil
}
return errors.ErrNoVolumesDetected
}
// Mount will return a mount point path when specifying either a volumeName
// or volumeID. If a overwriteFs boolean is specified it will overwrite
// the FS based on newFsType if it is detected that there is no FS present.
func (r *vdm) Mount(
volumeName, volumeID string,
overwriteFs bool, newFsType string, preempt bool) (string, error) {
for _, d := range r.drivers {
if !preempt {
preempt = r.rexray.Config.GetBool("rexray.volume.mount.preempt")
}
return d.Mount(volumeName, volumeID, overwriteFs, newFsType, preempt)
}
return "", errors.ErrNoVolumesDetected
}
// Unmount will unmount the specified volume by volumeName or volumeID.
func (r *vdm) Unmount(volumeName, volumeID string) error {
for _, d := range r.drivers {
return d.Unmount(volumeName, volumeID)
}
return errors.ErrNoVolumesDetected
}
// Path will return the mounted path of the volumeName or volumeID.
func (r *vdm) Path(volumeName, volumeID string) (string, error) {
for _, d := range r.drivers {
return d.Path(volumeName, volumeID)
}
return "", errors.ErrNoVolumesDetected
}
// Create will create a new volume with the volumeName and opts.
func (r *vdm) Create(volumeName string, opts VolumeOpts) error {
for _, d := range r.drivers {
return d.Create(volumeName, opts)
}
return errors.ErrNoVolumesDetected
}
// Remove will remove a volume of volumeName.
func (r *vdm) Remove(volumeName string) error {
for _, d := range r.drivers {
return d.Remove(volumeName)
}
return errors.ErrNoVolumesDetected
}
// Attach will attach a volume based on volumeName to the instance of
// instanceID.
func (r *vdm) Attach(volumeName, instanceID string, force bool) (string, error) {
for _, d := range r.drivers {
return d.Attach(volumeName, instanceID, force)
}
return "", errors.ErrNoVolumesDetected
}
// Detach will detach a volume based on volumeName to the instance of
// instanceID.
func (r *vdm) Detach(volumeName, instanceID string, force bool) error {
for _, d := range r.drivers {
return d.Detach(volumeName, instanceID, force)
}
return errors.ErrNoVolumesDetected
}
// NetworkName will return an identifier of a volume that is relevant when
// corelating a local device to a device that is the volumeName to the
// local instanceID.
func (r *vdm) NetworkName(volumeName, instanceID string) (string, error) {
for _, d := range r.drivers {
return d.NetworkName(volumeName, instanceID)
}
return "", errors.ErrNoVolumesDetected
}