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
|
package driver
import (
"github.com/container-storage-interface/spec/lib/go/csi"
"github.com/golang/glog"
)
const (
driverName = "csi.seaweedfs.com"
)
var (
version = "1.0.0-rc1"
)
type SeaweedFsDriver struct {
name string
nodeID string
version string
endpoint string
vcap []*csi.VolumeCapability_AccessMode
cscap []*csi.ControllerServiceCapability
filer string
pathOnFiler string
}
func NewSeaweedFsDriver(nodeID, endpoint string) *SeaweedFsDriver {
glog.Infof("Driver: %v version: %v", driverName, version)
n := &SeaweedFsDriver{
endpoint: endpoint,
nodeID: nodeID,
name: driverName,
version: version,
}
n.AddVolumeCapabilityAccessModes([]csi.VolumeCapability_AccessMode_Mode{
csi.VolumeCapability_AccessMode_MULTI_NODE_MULTI_WRITER,
})
n.AddControllerServiceCapabilities([]csi.ControllerServiceCapability_RPC_Type{
csi.ControllerServiceCapability_RPC_CREATE_DELETE_VOLUME,
})
return n
}
func NewNodeServer(n *SeaweedFsDriver) *NodeServer {
return &NodeServer{
Driver: n,
}
}
func (n *SeaweedFsDriver) Run() {
s := NewNonBlockingGRPCServer()
s.Start(n.endpoint,
NewIdentityServer(n),
NewControllerServer(n),
NewNodeServer(n))
s.Wait()
}
func (n *SeaweedFsDriver) AddVolumeCapabilityAccessModes(vc []csi.VolumeCapability_AccessMode_Mode) []*csi.VolumeCapability_AccessMode {
var vca []*csi.VolumeCapability_AccessMode
for _, c := range vc {
glog.Infof("Enabling volume access mode: %v", c.String())
vca = append(vca, &csi.VolumeCapability_AccessMode{Mode: c})
}
n.vcap = vca
return vca
}
func (n *SeaweedFsDriver) AddControllerServiceCapabilities(cl []csi.ControllerServiceCapability_RPC_Type) {
var csc []*csi.ControllerServiceCapability
for _, c := range cl {
glog.Infof("Enabling controller service capability: %v", c.String())
csc = append(csc, NewControllerServiceCapability(c))
}
n.cscap = csc
return
}
func (n *SeaweedFsDriver) createBucket(volumeId string, seaweedFsVolumeCount int) error {
// TODO implement seaweedFsVolumeCount later
return nil
}
func (n *SeaweedFsDriver) deleteBucket(volumeId string) error {
return nil
}
func (n *SeaweedFsDriver) mount(source string, targetPath string) error {
return nil
}
func (n *SeaweedFsDriver) unmount(targetPath string) error {
return nil
}
|
