server: send vgrc to clients

Signed-off-by: Rewant Soni <[email protected]>

Author: rewantsoni

controllers/util/groupreplicationclasses.go

@@ -0,0 +1,74 @@
+package util
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"slices"
+
+	ocsv1a1 "github.com/red-hat-storage/ocs-operator/api/v4/v1alpha1"
+
+	replicationv1alpha1 "github.com/csi-addons/kubernetes-csi-addons/api/replication.storage/v1alpha1"
+	templatev1 "github.com/openshift/api/template/v1"
+	"sigs.k8s.io/controller-runtime/pkg/client"
+)
+
+const (
+	ramenDRStorageIDLabelKey     = "ramendr.openshift.io/storageid"
+	ramenDRReplicationIDLabelKey = "ramendr.openshift.io/replicationid"
+	ramenMaintenanceModeLabelKey = "ramendr.openshift.io/maintenancemodes"
+)
+
+func VolumeGroupReplicationClassFromTemplate(
+	ctx context.Context,
+	kubeClient client.Client,
+	volumeGroupReplicationClassName string,
+	consumer *ocsv1a1.StorageConsumer,
+	consumerConfig StorageConsumerResources,
+	rbdStorageId,
+	remoteRbdStorageId string,
+) (*replicationv1alpha1.VolumeGroupReplicationClass, error) {
+	replicationClassName := volumeGroupReplicationClassName
+	//TODO: The code is written under the assumption VGRC name is exactly the same as the template name and there
+	// is 1:1 mapping between template and vgrc. The restriction will be relaxed in the future
+	vgrcTemplate := &templatev1.Template{}
+	vgrcTemplate.Name = replicationClassName
+	vgrcTemplate.Namespace = consumer.Namespace
+
+	if err := kubeClient.Get(ctx, client.ObjectKeyFromObject(vgrcTemplate), vgrcTemplate); err != nil {
+		return nil, fmt.Errorf("failed to get VolumeGroupReplicationClass template: %s, %v", replicationClassName, err)
+	}
+
+	if len(vgrcTemplate.Objects) != 1 {
+		return nil, fmt.Errorf("unexpected number of Volume Group Replication Class found expected 1")
+	}
+
+	vgrc := &replicationv1alpha1.VolumeGroupReplicationClass{}
+	if err := json.Unmarshal(vgrcTemplate.Objects[0].Raw, vgrc); err != nil {
+		return nil, fmt.Errorf("failed to unmarshall volume group replication class: %s, %v", replicationClassName, err)
+
+	}
+
+	if vgrc.Name != replicationClassName {
+		return nil, fmt.Errorf("volume group replication class name mismatch: %s, %v", replicationClassName, vgrc.Name)
+	}
+
+	switch vgrc.Spec.Provisioner {
+	case RbdDriverName:
+		// For VGRC the replicationID will be a combination of RBDStorageID, RemoteRBDStorageID and the poolName
+		// pool name is added to the VGRC's template
+		poolName := vgrc.Spec.Parameters["pool"]
+		storageIDs := []string{rbdStorageId, remoteRbdStorageId, poolName}
+		slices.Sort(storageIDs)
+		replicationID := CalculateMD5Hash(storageIDs)
+		vgrc.Spec.Parameters["replication.storage.openshift.io/group-replication-secret-name"] = consumerConfig.GetCsiRbdProvisionerCephUserName()
+		vgrc.Spec.Parameters["replication.storage.openshift.io/group-replication-secret-namespace"] = consumer.Status.Client.OperatorNamespace
+		vgrc.Spec.Parameters["clusterID"] = consumerConfig.GetRbdClientProfileName()
+		AddLabel(vgrc, ramenDRStorageIDLabelKey, rbdStorageId)
+		AddLabel(vgrc, ramenMaintenanceModeLabelKey, "Failover")
+		AddLabel(vgrc, ramenDRReplicationIDLabelKey, replicationID)
+	default:
+		return nil, fmt.Errorf("unsupported Provisioner for VolumeGroupReplicationClass")
+	}
+	return vgrc, nil
+}

deploy/csv-templates/ocs-operator.csv.yaml.in

@@ -80,7 +80,7 @@ metadata:
           "spec": null
         }
       ]
-    createdAt: "2025-07-15T15:37:59Z"
+    createdAt: "2025-07-16T06:14:16Z"
     description: Red Hat OpenShift Container Storage provides hyperconverged storage
       for applications within an OpenShift cluster.
     operators.operatorframework.io/builder: operator-sdk-v1.30.0

deploy/ocs-operator/manifests/ocs-operator.clusterserviceversion.yaml

@@ -57,7 +57,7 @@ metadata:
     capabilities: Deep Insights
     categories: Storage
     containerImage: quay.io/ocs-dev/ocs-operator:latest
-    createdAt: "2025-07-15T15:37:59Z"
+    createdAt: "2025-07-16T06:14:16Z"
     description: Red Hat OpenShift Container Storage provides hyperconverged storage
       for applications within an OpenShift cluster.
     external.features.ocs.openshift.io/supported-platforms: '["BareMetal", "None",

metrics/go.mod

@@ -55,6 +55,7 @@ require (
 	github.com/cloudnative-pg/cloudnative-pg v1.25.1 // indirect
 	github.com/cloudnative-pg/machinery v0.1.0 // indirect
 	github.com/containernetworking/cni v1.2.3 // indirect
+	github.com/csi-addons/kubernetes-csi-addons v0.12.0 // indirect
 	github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc // indirect
 	github.com/emicklei/go-restful/v3 v3.12.2 // indirect
 	github.com/evanphx/json-patch/v5 v5.9.11 // indirect

metrics/go.sum

@@ -205,6 +205,8 @@ github.com/cpuguy83/go-md2man v1.0.10/go.mod h1:SmD6nW6nTyfqj6ABTjUi3V3JVMnlJmwc
 github.com/cpuguy83/go-md2man/v2 v2.0.0/go.mod h1:maD7wRr/U5Z6m/iR4s+kqSMx2CaBsrgA7czyZG/E6dU=
 github.com/creack/pty v1.1.7/go.mod h1:lj5s0c3V2DBrqTV7llrYr5NG6My20zk30Fl46Y7DoTY=
 github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E=
+github.com/csi-addons/kubernetes-csi-addons v0.12.0 h1:RbF2dCjWV4ljynibEOkA0wbwwt/09awjOKgEFC14Bns=
+github.com/csi-addons/kubernetes-csi-addons v0.12.0/go.mod h1:8vrXJUZrlI2ms2aZ6qRfp8ieRlpHEefTX5azOFi67o0=
 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=