aboutsummaryrefslogtreecommitdiff
path: root/pkg/driver/driver.go
diff options
context:
space:
mode:
authorViktor Kuzmin <kvaster@gmail.com>2023-08-07 00:42:37 +0300
committerChris Lu <chrislusf@users.noreply.github.com>2023-08-07 10:22:05 -0700
commita332490d221b5b1c59c6bfd530c559e38632ccf9 (patch)
treeeeff873984bfa1ba66261fecf1923c0d71638b94 /pkg/driver/driver.go
parentb99b31a7890108edae3a6fa7672077cd5f67aaf0 (diff)
downloadseaweedfs-csi-driver-a332490d221b5b1c59c6bfd530c559e38632ccf9.tar.xz
seaweedfs-csi-driver-a332490d221b5b1c59c6bfd530c559e38632ccf9.zip
Fix Add...Capability functions - capabilities now added instead of replaced
Diffstat (limited to 'pkg/driver/driver.go')
-rw-r--r--pkg/driver/driver.go15
1 files changed, 3 insertions, 12 deletions
diff --git a/pkg/driver/driver.go b/pkg/driver/driver.go
index 12954e9..20a6fa5 100644
--- a/pkg/driver/driver.go
+++ b/pkg/driver/driver.go
@@ -119,27 +119,18 @@ func (n *SeaweedFsDriver) Run() {
glog.Infof("stopped")
}
-func (n *SeaweedFsDriver) AddVolumeCapabilityAccessModes(vc []csi.VolumeCapability_AccessMode_Mode) []*csi.VolumeCapability_AccessMode {
- var vca []*csi.VolumeCapability_AccessMode
+func (n *SeaweedFsDriver) AddVolumeCapabilityAccessModes(vc []csi.VolumeCapability_AccessMode_Mode) {
for _, c := range vc {
glog.Infof("Enabling volume access mode: %v", c.String())
- vca = append(vca, &csi.VolumeCapability_AccessMode{Mode: c})
+ n.vcap = append(n.vcap, &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 = append(n.cscap, NewControllerServiceCapability(c))
}
-
- n.cscap = csc
-
- return
}
func (d *SeaweedFsDriver) ValidateControllerServiceRequest(c csi.ControllerServiceCapability_RPC_Type) error {