Loading pkg/driver/controllerserver.go +1 −2 Original line number Diff line number Diff line Loading @@ -170,9 +170,8 @@ func (cs *controllerServer) ValidateVolumeCapabilities(ctx context.Context, req return nil, status.Error(codes.NotFound, fmt.Sprintf("bucket of volume with id %s does not exist", req.GetVolumeId())) } // We currently only support RWO supportedAccessMode := &csi.VolumeCapability_AccessMode{ Mode: csi.VolumeCapability_AccessMode_SINGLE_NODE_WRITER, Mode: csi.VolumeCapability_AccessMode_MULTI_NODE_MULTI_WRITER, } for _, capability := range req.VolumeCapabilities { Loading pkg/driver/driver.go +1 −1 Original line number Diff line number Diff line Loading @@ -75,7 +75,7 @@ func (s3 *driver) Run() { // Initialize default library driver s3.driver.AddControllerServiceCapabilities([]csi.ControllerServiceCapability_RPC_Type{csi.ControllerServiceCapability_RPC_CREATE_DELETE_VOLUME}) s3.driver.AddVolumeCapabilityAccessModes([]csi.VolumeCapability_AccessMode_Mode{csi.VolumeCapability_AccessMode_SINGLE_NODE_WRITER}) s3.driver.AddVolumeCapabilityAccessModes([]csi.VolumeCapability_AccessMode_Mode{csi.VolumeCapability_AccessMode_MULTI_NODE_MULTI_WRITER}) // Create GRPC servers s3.ids = s3.newIdentityServer(s3.driver) Loading Loading
pkg/driver/controllerserver.go +1 −2 Original line number Diff line number Diff line Loading @@ -170,9 +170,8 @@ func (cs *controllerServer) ValidateVolumeCapabilities(ctx context.Context, req return nil, status.Error(codes.NotFound, fmt.Sprintf("bucket of volume with id %s does not exist", req.GetVolumeId())) } // We currently only support RWO supportedAccessMode := &csi.VolumeCapability_AccessMode{ Mode: csi.VolumeCapability_AccessMode_SINGLE_NODE_WRITER, Mode: csi.VolumeCapability_AccessMode_MULTI_NODE_MULTI_WRITER, } for _, capability := range req.VolumeCapabilities { Loading
pkg/driver/driver.go +1 −1 Original line number Diff line number Diff line Loading @@ -75,7 +75,7 @@ func (s3 *driver) Run() { // Initialize default library driver s3.driver.AddControllerServiceCapabilities([]csi.ControllerServiceCapability_RPC_Type{csi.ControllerServiceCapability_RPC_CREATE_DELETE_VOLUME}) s3.driver.AddVolumeCapabilityAccessModes([]csi.VolumeCapability_AccessMode_Mode{csi.VolumeCapability_AccessMode_SINGLE_NODE_WRITER}) s3.driver.AddVolumeCapabilityAccessModes([]csi.VolumeCapability_AccessMode_Mode{csi.VolumeCapability_AccessMode_MULTI_NODE_MULTI_WRITER}) // Create GRPC servers s3.ids = s3.newIdentityServer(s3.driver) Loading