rpc: add rpc calls to create the maintenance mode reconciler in ocs-operator

controllers/storageconsumer/storageconsumer_controller.go

@@ -51,6 +51,7 @@ const (
 	StorageProfileLabel           = "ocs.openshift.io/storageprofile"
 	ConsumerUUIDLabel             = "ocs.openshift.io/storageconsumer-uuid"
 	StorageConsumerNameLabel      = "ocs.openshift.io/storageconsumer-name"
+	MaintenanceModeLabel          = "ocs.openshift.io/maintenanceMode"
 )
 
 // StorageConsumerReconciler reconciles a StorageConsumer object

controllers/util/util.go

@@ -89,6 +89,19 @@ func AddLabel(obj metav1.Object, key string, value string) bool {
 	return false
 }
 
+func RemoveLabel(obj metav1.Object, key string) bool {
+	labels := obj.GetLabels()
+	if labels == nil {
+		return false
+	}
+	if _, exists := labels[key]; exists {
+		delete(labels, key)
+		obj.SetLabels(labels)
+		return true
+	}
+	return false
+}
+
 func CalculateMD5Hash(value any) string {
 	data, err := json.Marshal(value)
 	if err != nil {

deploy/ocs-operator/manifests/provider-role.yaml

@@ -11,6 +11,13 @@ rules:
       - services
     verbs:
       - get
+  - apiGroups:
+      - apps
+    resources:
+      - deployments
+    verbs:
+      - get
+      - list
   - apiGroups:
       - ceph.rook.io
     resources:

rbac/provider-role.yaml

@@ -11,6 +11,13 @@ rules:
       - services
     verbs:
       - get
+  - apiGroups:
+      - apps
+    resources:
+      - deployments
+    verbs:
+      - get
+      - list
   - apiGroups:
       - ceph.rook.io
     resources:

services/provider/api/client/client.go

@@ -226,4 +226,50 @@ func (cc *OCSProviderClient) PeerStorageCluster(ctx context.Context, onboardingT
 	defer cancel()
 
 	return cc.Client.PeerStorageCluster(apiCtx, req)
+
+}
+
+func (cc *OCSProviderClient) StartMaintenanceMode(ctx context.Context, consumerUUID string) (*pb.StartMaintenanceModeResponse, error) {
+	if cc.Client == nil || cc.clientConn == nil {
+		return nil, fmt.Errorf("provider client is closed")
+	}
+
+	req := &pb.StartMaintenanceModeRequest{
+		StorageConsumerUUID: consumerUUID,
+	}
+
+	apiCtx, cancel := context.WithTimeout(ctx, cc.timeout)
+	defer cancel()
+
+	return cc.Client.StartMaintenanceMode(apiCtx, req)
+}
+
+func (cc *OCSProviderClient) StopMaintenanceMode(ctx context.Context, consumerUUID string) (*pb.StopMaintenanceModeResponse, error) {
+	if cc.Client == nil || cc.clientConn == nil {
+		return nil, fmt.Errorf("provider client is closed")
+	}
+
+	req := &pb.StopMaintenanceModeRequest{
+		StorageConsumerUUID: consumerUUID,
+	}
+
+	apiCtx, cancel := context.WithTimeout(ctx, cc.timeout)
+	defer cancel()
+
+	return cc.Client.StopMaintenanceMode(apiCtx, req)
+}
+
+func (cc *OCSProviderClient) GetMaintenanceModeStatus(ctx context.Context, consumerUUID string) (*pb.GetMaintenanceModeStatusResponse, error) {
+	if cc.Client == nil || cc.clientConn == nil {
+		return nil, fmt.Errorf("provider client is closed")
+	}
+
+	req := &pb.GetMaintenanceModeStatusRequest{
+		StorageConsumerUUID: consumerUUID,
+	}
+
+	apiCtx, cancel := context.WithTimeout(ctx, cc.timeout)
+	defer cancel()
+
+	return cc.Client.GetMaintenanceModeStatus(apiCtx, req)
 }