controllers: new controller for maintenance mode

Signed-off-by: Rewant Soni <[email protected]>
red-hat-storage · Nov 20, 2024 · a71be92 · a71be92
1 parent 64a0317
commit a71be92
Show file tree

Hide file tree

Showing 20 changed files with 1,022 additions and 193 deletions.
diff --git a/api/v1alpha1/storageclient_types.go b/api/v1alpha1/storageclient_types.go
@@ -46,10 +46,16 @@ type StorageClientSpec struct {
 	OnboardingTicket string `json:"onboardingTicket"`
 }
 
+type ProviderAttributes struct {
+	InMaintenanceMode bool `json:"inMaintenanceMode"`
+}
+
 // StorageClientStatus defines the observed state of StorageClient
 type StorageClientStatus struct {
 	Phase storageClientPhase `json:"phase,omitempty"`
 
+	Provider ProviderAttributes `json:"providerAttributes,omitempty"`
+
 	// ConsumerID will hold the identity of this cluster inside the attached provider cluster
 	ConsumerID string `json:"id,omitempty"`
 }

diff --git a/api/v1alpha1/zz_generated.deepcopy.go b/api/v1alpha1/zz_generated.deepcopy.go
diff --git a/bundle/manifests/ocs-client-operator.clusterserviceversion.yaml b/bundle/manifests/ocs-client-operator.clusterserviceversion.yaml
@@ -7,7 +7,7 @@ metadata:
     categories: Storage
     console.openshift.io/plugins: '["odf-client-console"]'
     containerImage: quay.io/ocs-dev/ocs-client-operator:latest
-    createdAt: "2024-10-29T07:06:57Z"
+    createdAt: "2024-11-20T10:08:25Z"
     description: OpenShift Data Foundation client operator enables consumption of
       storage services from a remote centralized OpenShift Data Foundation provider
       cluster.
@@ -315,6 +315,31 @@ spec:
           - list
           - update
           - watch
+        - apiGroups:
+          - ramendr.openshift.io
+          resources:
+          - maintenancemodes
+          verbs:
+          - create
+          - delete
+          - get
+          - list
+          - update
+          - watch
+        - apiGroups:
+          - ramendr.openshift.io
+          resources:
+          - maintenancemodes/finalizers
+          verbs:
+          - update
+        - apiGroups:
+          - ramendr.openshift.io
+          resources:
+          - maintenancemodes/status
+          verbs:
+          - get
+          - patch
+          - update
         - apiGroups:
           - security.openshift.io
           resources:

diff --git a/bundle/manifests/ocs.openshift.io_storageclients.yaml b/bundle/manifests/ocs.openshift.io_storageclients.yaml
@@ -67,6 +67,13 @@ spec:
                 type: string
               phase:
                 type: string
+              providerAttributes:
+                properties:
+                  inMaintenanceMode:
+                    type: boolean
+                required:
+                - inMaintenanceMode
+                type: object
             type: object
         type: object
     served: true

diff --git a/cmd/main.go b/cmd/main.go
@@ -174,6 +174,7 @@ func main() {
 		Client:            mgr.GetClient(),
 		Scheme:            mgr.GetScheme(),
 		OperatorNamespace: utils.GetOperatorNamespace(),
+		AvailableCrds:     availCrds,
 	}).SetupWithManager(mgr); err != nil {
 		setupLog.Error(err, "unable to create controller", "controller", "StorageClient")
 		os.Exit(1)
@@ -208,6 +209,17 @@ func main() {
 		os.Exit(1)
 	}
 
+	if availCrds[controller.MaintenanceModeCRDName] {
+		if err = (&controller.MaintenanceModeReconciler{
+			Client:            mgr.GetClient(),
+			Scheme:            mgr.GetScheme(),
+			OperatorNamespace: utils.GetOperatorNamespace(),
+		}).SetupWithManager(mgr); err != nil {
+			setupLog.Error(err, "unable to create controller", "controller", "MaintenanceMode")
+			os.Exit(1)
+		}
+	}
+
 	setupLog.Info("starting manager")
 	if err := mgr.Start(ctrl.SetupSignalHandler()); err != nil {
 		setupLog.Error(err, "problem running manager")

diff --git a/config/crd/bases/ocs.openshift.io_storageclients.yaml b/config/crd/bases/ocs.openshift.io_storageclients.yaml
@@ -67,6 +67,13 @@ spec:
                 type: string
               phase:
                 type: string
+              providerAttributes:
+                properties:
+                  inMaintenanceMode:
+                    type: boolean
+                required:
+                - inMaintenanceMode
+                type: object
             type: object
         type: object
     served: true

diff --git a/config/rbac/role.yaml b/config/rbac/role.yaml
@@ -272,6 +272,31 @@ rules:
   - list
   - update
   - watch
+- apiGroups:
+  - ramendr.openshift.io
+  resources:
+  - maintenancemodes
+  verbs:
+  - create
+  - delete
+  - get
+  - list
+  - update
+  - watch
+- apiGroups:
+  - ramendr.openshift.io
+  resources:
+  - maintenancemodes/finalizers
+  verbs:
+  - update
+- apiGroups:
+  - ramendr.openshift.io
+  resources:
+  - maintenancemodes/status
+  verbs:
+  - get
+  - patch
+  - update
 - apiGroups:
   - security.openshift.io
   resources:

diff --git a/go.mod b/go.mod
@@ -5,6 +5,7 @@ go 1.22.5
 replace (
 	github.com/portworx/sched-ops => github.com/portworx/sched-ops v0.20.4-openstorage-rc3 // required by Rook v1.12
 	github.com/red-hat-storage/ocs-client-operator/api => ./api
+	github.com/red-hat-storage/ocs-operator/services/provider/api/v4 => github.com/rewantsoni/ocs-operator/services/provider/api/v4 v4.0.0-20241120091532-b37491f9205f
 	vbom.ml/util => github.com/fvbommel/util v0.0.0-20180919145318-efcd4e0f9787
 )
 

diff --git a/go.sum b/go.sum
@@ -325,8 +325,8 @@ github.com/prometheus/procfs v0.15.1 h1:YagwOFzUgYfKKHX6Dr+sHT7km/hxC76UB0leargg
 github.com/prometheus/procfs v0.15.1/go.mod h1:fB45yRUv8NstnjriLhBQLuOUt+WW4BsoGhij/e3PBqk=
 github.com/ramendr/ramen/api v0.0.0-20241001141243-29d6f22ad237 h1:ig6ePD0yopC5Qi5BRmhsIsKaOkdsGXTSmG3HTYIpquo=
 github.com/ramendr/ramen/api v0.0.0-20241001141243-29d6f22ad237/go.mod h1:nO6VM/+PEhcPGyFIQJdhY6ip822cA61PAy/s6IjenAA=
-github.com/red-hat-storage/ocs-operator/services/provider/api/v4 v4.0.0-20241015071140-98c8184c6eec h1:M64BdwKMV3jKxcRsZiaGbRKsvlbhRGVZgcb4V/MFeWk=
-github.com/red-hat-storage/ocs-operator/services/provider/api/v4 v4.0.0-20241015071140-98c8184c6eec/go.mod h1:t9GJk69TGXABBF8fFPB+ImpbA9mJyRS86wW6+Qn8xHo=
+github.com/rewantsoni/ocs-operator/services/provider/api/v4 v4.0.0-20241120091532-b37491f9205f h1:Tkgc2CD55guejpXUlxBMcDk/0NRR83k1Hj/QCHvJ3EA=
+github.com/rewantsoni/ocs-operator/services/provider/api/v4 v4.0.0-20241120091532-b37491f9205f/go.mod h1:t9GJk69TGXABBF8fFPB+ImpbA9mJyRS86wW6+Qn8xHo=
 github.com/rogpeppe/go-internal v1.3.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4=
 github.com/rogpeppe/go-internal v1.12.0 h1:exVL4IDcn6na9z1rAb56Vxr+CgyK3nn3O+epU5NdKM8=
 github.com/rogpeppe/go-internal v1.12.0/go.mod h1:E+RYuTGaKKdloAfM02xzb0FW3Paa99yedzYV+kq4uf4=