controllers: create VRCs

Signed-off-by: raaizik <[email protected]>

config/rbac/role.yaml

@@ -266,11 +266,8 @@ rules:
   resources:
   - drclusterconfigs
   verbs:
-  - create
-  - delete
   - get
   - list
-  - update
   - watch
 - apiGroups:
   - security.openshift.io

go.mod

@@ -15,6 +15,35 @@ exclude (
 	// than v0.x releases but are picked when updating dependencies.
 	k8s.io/client-go v11.0.1-0.20190409021438-1a26190bd76a+incompatible
 	k8s.io/client-go v12.0.0+incompatible
+	k8s.io/client-go v12.0.0+incompatible => k8s.io/client-go v0.29.0
+	vbom.ml/util => github.com/fvbommel/util v0.0.0-20180919145318-efcd4e0f9787
+)
+
+exclude github.com/kubernetes-incubator/external-storage v0.20.4-openstorage-rc2
+
+require (
+	github.com/ceph/ceph-csi-operator/api v0.0.0-20240807110810-f92ddf7cc527
+	github.com/csi-addons/kubernetes-csi-addons v0.8.0
+	github.com/go-logr/logr v1.4.1
+	github.com/kubernetes-csi/external-snapshotter/client/v6 v6.3.0
+	github.com/onsi/ginkgo v1.16.5
+	github.com/onsi/gomega v1.32.0
+	github.com/openshift/api v0.0.0-20240323003854-2252c7adfb79
+	github.com/operator-framework/api v0.22.0
+	github.com/pkg/errors v0.9.1
+	github.com/prometheus-operator/prometheus-operator/pkg/apis/monitoring v0.72.0
+	github.com/ramendr/ramen/api v0.0.0-20240726141352-b1af569f057c
+	github.com/red-hat-storage/ocs-operator/v4 v4.0.0-20240422111920-faced96485bc
+	github.com/stretchr/testify v1.9.0
+	google.golang.org/grpc v1.62.1
+	gopkg.in/yaml.v2 v2.4.0
+	k8s.io/api v0.30.3
+	k8s.io/apiextensions-apiserver v0.30.1
+	k8s.io/apimachinery v0.30.3
+	k8s.io/client-go v0.30.1
+	k8s.io/klog/v2 v2.120.1
+	k8s.io/utils v0.0.0-20240310230437-4693a0247e57
+	sigs.k8s.io/controller-runtime v0.18.4
 )
 
 require (

go.sum

@@ -66,6 +66,8 @@ github.com/cncf/udpa/go v0.0.0-20191209042840-269d4d468f6f/go.mod h1:M8M6+tZqaGX
 github.com/cncf/udpa/go v0.0.0-20200629203442-efcf912fb354/go.mod h1:WmhPx2Nbnhtbo57+VJT5O0JRkEi1Wbu0z5j0R8u5Hbk=
 github.com/cncf/udpa/go v0.0.0-20201120205902-5459f2c99403/go.mod h1:WmhPx2Nbnhtbo57+VJT5O0JRkEi1Wbu0z5j0R8u5Hbk=
 github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E=
+github.com/csi-addons/kubernetes-csi-addons v0.8.0 h1:zvYGp4DM6KdQzEX3dQSYKykqJdLZlxpVBJjtpbaqFjs=
+github.com/csi-addons/kubernetes-csi-addons v0.8.0/go.mod h1:dvinzoiXlqdOGDpKkYx8Jxl507BzVEEEO+SI0OmBaRI=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc h1:U9qPSI2PIWSS1VwoXQT9A3Wy9MM3WgvqSxFWenqJduM=

internal/controller/storageclaim_controller.go

@@ -25,11 +25,16 @@ import (
 	"strings"
 	"time"
 
+	"k8s.io/apimachinery/pkg/types"
+	"sigs.k8s.io/controller-runtime/pkg/event"
+	"sigs.k8s.io/controller-runtime/pkg/handler"
+
 	v1alpha1 "github.com/red-hat-storage/ocs-client-operator/api/v1alpha1"
 	"github.com/red-hat-storage/ocs-client-operator/pkg/templates"
 	"github.com/red-hat-storage/ocs-client-operator/pkg/utils"
 
 	csiopv1a1 "github.com/ceph/ceph-csi-operator/api/v1alpha1"
+	replicationv1alpha1 "github.com/csi-addons/kubernetes-csi-addons/apis/replication.storage/v1alpha1"
 	"github.com/go-logr/logr"
 	snapapi "github.com/kubernetes-csi/external-snapshotter/client/v6/apis/volumesnapshot/v1"
 	ramenv1alpha1 "github.com/ramendr/ramen/api/v1alpha1"
@@ -112,9 +117,44 @@ func (r *StorageClaimReconciler) SetupWithManager(mgr ctrl.Manager) error {
 		return fmt.Errorf("unable to set up FieldIndexer for VSC csi driver name: %v", err)
 	}
 
+	enqueueVolumeReplicationClass := handler.EnqueueRequestsFromMapFunc(
+		func(context context.Context, obj client.Object) []reconcile.Request {
+			vrcs := &replicationv1alpha1.VolumeReplicationClassList{}
+			err := r.Client.List(context, vrcs, &client.ListOptions{Namespace: obj.GetNamespace()})
+			if err != nil {
+				r.log.Error(err, "Unable to list VolumeReplicationClass objects")
+				return []reconcile.Request{}
+			}
+
+			// Return name and namespace of the VolumeReplicationClass object
+			request := []reconcile.Request{}
+			for _, vrc := range vrcs.Items {
+				request = append(request, reconcile.Request{
+					NamespacedName: types.NamespacedName{
+						Namespace: vrc.Namespace,
+						Name:      vrc.Name,
+					},
+				})
+			}
+			return request
+		},
+	)
+
+	drClusterConfigPredicate := predicate.Funcs{
+		UpdateFunc: func(e event.UpdateEvent) bool {
+			if e.ObjectOld == nil || e.ObjectNew == nil {
+				return false
+			}
+			oldObj := e.ObjectOld.(*ramenv1alpha1.DRClusterConfig)
+			newObj := e.ObjectNew.(*ramenv1alpha1.DRClusterConfig)
+			return !reflect.DeepEqual(oldObj.Spec, newObj.Spec)
+		},
+	}
 	generationChangePredicate := predicate.GenerationChangedPredicate{}
 	bldr := ctrl.NewControllerManagedBy(mgr).
 		For(&v1alpha1.StorageClaim{}, builder.WithPredicates(generationChangePredicate)).
+		Watches(&ramenv1alpha1.DRClusterConfig{}, enqueueVolumeReplicationClass,
+			builder.WithPredicates(drClusterConfigPredicate)).
 		Owns(&storagev1.StorageClass{}).
 		Owns(&snapapi.VolumeSnapshotClass{}).
 		Watches(
@@ -143,6 +183,7 @@ func (r *StorageClaimReconciler) SetupWithManager(mgr ctrl.Manager) error {
 //+kubebuilder:rbac:groups=snapshot.storage.k8s.io,resources=volumesnapshotclasses,verbs=get;list;watch;create;delete
 //+kubebuilder:rbac:groups=core,resources=persistentvolumes,verbs=get;list;watch
 //+kubebuilder:rbac:groups=snapshot.storage.k8s.io,resources=volumesnapshotcontents,verbs=get;list;watch
+//+kubebuilder:rbac:groups=ramendr.openshift.io,resources=drclusterconfigs,verbs=get;list;watch
 //+kubebuilder:rbac:groups=csi.ceph.io,resources=clientprofiles,verbs=get;list;update;create;watch;delete
 //+kubebuilder:rbac:groups=ramendr.openshift.io,resources=drclusterconfigs,verbs=get;list;update;create;watch;delete