Add support for expanding volumes

deploy/k8s/bases/csi-beegfs-controller.yaml

@@ -48,6 +48,27 @@ spec:
             requests:
               cpu: 80m
               memory: 24Mi
+        - name: csi-resizer
+          image: registry.k8s.io/sig-storage/csi-resizer:v1.11.1
+          args:
+            - "--csi-address=/csi/csi.sock"
+            - -v=$(LOG_LEVEL)            
+          securityContext:
+            # On SELinux enabled systems, a non-privileged sidecar container cannot access the unix domain socket
+            # created by the privileged driver container.
+            privileged: true            
+          env:
+            - name: LOG_LEVEL
+              value: "3"             
+          volumeMounts:
+            - mountPath: /csi
+              name: socket-dir
+          resources:
+            limits:
+              memory: 500Mi
+            requests:
+              cpu: 10m
+              memory: 20Mi           
         - name: beegfs
           image: ghcr.io/thinkparq/beegfs-csi-driver:v1.6.0
           args:

deploy/k8s/bases/csi-beegfs-rbac.yaml

@@ -24,10 +24,10 @@ metadata:
 rules:
   - apiGroups: [""]
     resources: ["persistentvolumes"]
-    verbs: ["get", "list", "watch", "create", "delete"]
+    verbs: ["get", "list", "watch", "create", "delete", "patch"]
   - apiGroups: [""]
     resources: ["persistentvolumeclaims"]
-    verbs: ["get", "list", "watch", "update"]
+    verbs: ["get", "list", "watch", "update", "patch"]
   - apiGroups: ["storage.k8s.io"]
     resources: ["storageclasses"]
     verbs: ["get", "list", "watch"]
@@ -40,6 +40,12 @@ rules:
   - apiGroups: [""]
     resources: ["nodes"]
     verbs: ["get", "list", "watch"]
+  - apiGroups: [""]
+    resources: ["pods"]
+    verbs: ["get", "list", "watch"]
+  - apiGroups: [""]
+    resources: ["persistentvolumeclaims/status"]
+    verbs: ["patch"]     
 
 ---
 

examples/k8s/dyn/dyn-sc.yaml

@@ -20,4 +20,4 @@ parameters:
   # permissions/mode: "0644"
 reclaimPolicy: Delete
 volumeBindingMode: Immediate
-allowVolumeExpansion: false
+allowVolumeExpansion: true

pkg/beegfs/controllerserver.go

@@ -43,6 +43,7 @@ var (
 	// controllerCaps represents the capabilities of the controller service
 	controllerCaps = []csi.ControllerServiceCapability_RPC_Type{
 		csi.ControllerServiceCapability_RPC_CREATE_DELETE_VOLUME,
+		csi.ControllerServiceCapability_RPC_EXPAND_VOLUME,
 	}
 )
 
@@ -378,7 +379,17 @@ func (cs *controllerServer) ListSnapshots(ctx context.Context, req *csi.ListSnap
 }
 
 func (cs *controllerServer) ControllerExpandVolume(ctx context.Context, req *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error) {
-	return nil, status.Error(codes.Unimplemented, "")
+	volumeID := req.GetVolumeId()
+	if len(volumeID) == 0 {
+		return nil, status.Error(codes.InvalidArgument, "Volume ID not provided")
+	}
+	// While currently volume "capacity" has no meaning as far as the driver is concerned, some
+	// applications rely on the capacity of the PV/PVC in the K8s API to make certain decisions.
+	// For these applications it is helpful to support volume resizing.
+	return &csi.ControllerExpandVolumeResponse{
+		CapacityBytes:         req.CapacityRange.RequiredBytes,
+		NodeExpansionRequired: false,
+	}, nil
 }
 
 func (cs *controllerServer) ControllerGetVolume(ctx context.Context, in *csi.ControllerGetVolumeRequest) (*csi.ControllerGetVolumeResponse, error) {

pkg/beegfs/identityserver.go

@@ -72,6 +72,13 @@ func (ids *identityServer) GetPluginCapabilities(ctx context.Context, req *csi.G
 					},
 				},
 			},
+			{
+				Type: &csi.PluginCapability_VolumeExpansion_{
+					VolumeExpansion: &csi.PluginCapability_VolumeExpansion{
+						Type: csi.PluginCapability_VolumeExpansion_ONLINE,
+					},
+				},
+			},
 		},
 	}, nil
 }

test/e2e/driver/driver.go

@@ -97,7 +97,7 @@ func initBaseBeegfsDriver(dynamicVolDirBasePathBeegfsRoot, staticVolDirPathBeegf
 				storageframework.CapPVCDataSource:       false,
 				storageframework.CapMultiPODs:           true,
 				storageframework.CapRWX:                 true,
-				storageframework.CapControllerExpansion: false,
+				storageframework.CapControllerExpansion: true,
 				storageframework.CapNodeExpansion:       false,
 				storageframework.CapVolumeLimits:        false,
 				// This setting is only used in two places, both in the multivolume test suite. Setting this to true