aboutsummaryrefslogtreecommitdiff
path: root/pkg/driver/controllerserver.go
diff options
context:
space:
mode:
authorchrislu <chrislu@roblox.com>2023-11-05 10:18:03 -0800
committerchrislu <chrislu@roblox.com>2023-11-05 10:18:03 -0800
commitad7f79db7cab8d13f65c2cdcf38f6b9c0415eecf (patch)
tree54d38e21031696ad36436288c8c56ca1901e3451 /pkg/driver/controllerserver.go
parent82ab464ce0afb19ceafddbade6fcaaec433ffc0f (diff)
parent51468113a2b01b6826c2d72dcc30b2c567be03cb (diff)
downloadseaweedfs-csi-driver-ad7f79db7cab8d13f65c2cdcf38f6b9c0415eecf.tar.xz
seaweedfs-csi-driver-ad7f79db7cab8d13f65c2cdcf38f6b9c0415eecf.zip
Merge branch 'master' of https://github.com/seaweedfs/seaweedfs-csi-driver
Diffstat (limited to 'pkg/driver/controllerserver.go')
-rw-r--r--pkg/driver/controllerserver.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/pkg/driver/controllerserver.go b/pkg/driver/controllerserver.go
index 57b43d0..0d8b671 100644
--- a/pkg/driver/controllerserver.go
+++ b/pkg/driver/controllerserver.go
@@ -54,7 +54,7 @@ func (cs *ControllerServer) CreateVolume(ctx context.Context, req *csi.CreateVol
}
if err := filer_pb.Mkdir(cs.Driver, "/buckets", volumeId, nil); err != nil {
- return nil, fmt.Errorf("Error setting bucket metadata: %v", err)
+ return nil, fmt.Errorf("error setting bucket metadata: %v", err)
}
glog.V(4).Infof("volume created %s", volumeId)
@@ -85,7 +85,7 @@ func (cs *ControllerServer) DeleteVolume(ctx context.Context, req *csi.DeleteVol
glog.V(4).Infof("deleting volume %s", volumeId)
if err := filer_pb.Remove(cs.Driver, "/buckets", volumeId, true, true, true, false, nil); err != nil {
- return nil, fmt.Errorf("Error setting bucket metadata: %v", err)
+ return nil, fmt.Errorf("error setting bucket metadata: %v", err)
}
return &csi.DeleteVolumeResponse{}, nil
@@ -137,7 +137,7 @@ func (cs *ControllerServer) ValidateVolumeCapabilities(ctx context.Context, req
exists, err := filer_pb.Exists(cs.Driver, "/buckets", req.GetVolumeId(), true)
if err != nil {
- return nil, fmt.Errorf("Error checking bucket %s exists: %v", req.GetVolumeId(), err)
+ return nil, fmt.Errorf("error checking bucket %s exists: %v", req.GetVolumeId(), err)
}
if !exists {
// return an error if the volume requested does not exist