add flag to block volume creation

Signed-off-by: Niclas Schad <niclas.schad@stackit.cloud>

Author: nschad

cmd/stackit-csi-plugin/main.go

@@ -25,6 +25,7 @@ var (
 	provideControllerService bool
 	provideNodeService       bool
 	legacyStorageMode        bool
+	blockVolumeCreation      bool
 )
 
 func main() {
@@ -75,6 +76,7 @@ func main() {
 		"If set to true then the CSI driver does provide the node service (default: true)")
 	cmd.PersistentFlags().BoolVar(&legacyStorageMode, "legacy-storage-mode", false,
 		"Configures the CSI to listen to the legacy storage driverName cinder.csi.openstack.org instead")
+	cmd.PersistentFlags().BoolVar(&blockVolumeCreation, "block-volume-creation", false, "Block volume creation")
 
 	stackit.AddExtraFlags(pflag.CommandLine)
 
@@ -94,6 +96,10 @@ func handle() {
 		driverOpts.LegacyDriverName = true
 	}
 
+	if blockVolumeCreation {
+		driverOpts.BlockVolumeCreation = true
+	}
+
 	d := blockstorage.NewDriver(driverOpts)
 
 	if provideControllerService {

pkg/csi/blockstorage/controllerserver.go

@@ -77,6 +77,10 @@ func (cs *controllerServer) CreateVolume(ctx context.Context, req *csi.CreateVol
 
 	cloud := cs.Instance
 
+	if cs.Driver.blockVolumeCreation {
+		return nil, status.Error(codes.FailedPrecondition, "CSI driver is in read/update-only mode")
+	}
+
 	// Volume Name
 	volName := req.GetName()
 	volCapabilities := req.GetVolumeCapabilities()
@@ -476,6 +480,10 @@ func (cs *controllerServer) CreateSnapshot(ctx context.Context, req *csi.CreateS
 
 	cloud := cs.Instance
 
+	if cs.Driver.blockVolumeCreation {
+		return nil, status.Error(codes.FailedPrecondition, "The old driver is update/read-only mode please migrate to the new driver")
+	}
+
 	name := req.Name
 	volumeID := req.GetSourceVolumeId()
 	snapshotType := req.Parameters[stackit.SnapshotType]

pkg/csi/blockstorage/driver.go

@@ -31,11 +31,12 @@ var (
 )
 
 type Driver struct {
-	name         string
-	fqVersion    string // Fully qualified version in format {Version}@{CPO version}
-	endpoint     string
-	clusterID    string
-	legacyDriver bool
+	name                string
+	fqVersion           string // Fully qualified version in format {Version}@{CPO version}
+	endpoint            string
+	clusterID           string
+	legacyDriver        bool
+	blockVolumeCreation bool
 
 	ids *identityServer
 	cs  *controllerServer
@@ -50,9 +51,10 @@ type Driver struct {
 }
 
 type DriverOpts struct {
-	ClusterID        string
-	Endpoint         string
-	LegacyDriverName bool
+	ClusterID           string
+	Endpoint            string
+	LegacyDriverName    bool
+	BlockVolumeCreation bool
 
 	PVCLister corev1.PersistentVolumeClaimLister
 }
@@ -71,6 +73,10 @@ func NewDriver(o *DriverOpts) *Driver {
 		d.legacyDriver = true
 	}
 
+	if o.BlockVolumeCreation {
+		d.blockVolumeCreation = true
+	}
+
 	klog.Info("Driver: ", d.name)
 	klog.Info("Driver version: ", d.fqVersion)
 	klog.Info("CSI Spec version: ", specVersion)