do not start cephfs cg controller if there is no volumegroupsnapshot CRD

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

config/dr-cluster/rbac/role.yaml

@@ -11,6 +11,12 @@ rules:
   verbs:
   - list
   - watch
+- apiGroups:
+  - apiextensions.k8s.io
+  resources:
+  - customresourcedefinitions
+  verbs:
+  - get
 - apiGroups:
   - groupsnapshot.storage.k8s.io
   resources:

config/rbac/role.yaml

@@ -39,6 +39,12 @@ rules:
   - patch
   - update
   - watch
+- apiGroups:
+  - apiextensions.k8s.io
+  resources:
+  - customresourcedefinitions
+  verbs:
+  - get
 - apiGroups:
   - apps.open-cluster-management.io
   resources:

controllers/replicationgroupsource_controller.go

@@ -63,6 +63,7 @@ type ReplicationGroupSourceReconciler struct {
 //+kubebuilder:rbac:groups=core,resources=persistentvolumeclaims,verbs=get;list;watch;create;update;patch;delete
 //+kubebuilder:rbac:groups=volsync.backube,resources=replicationsources,verbs=get;list;watch;create;update;patch;delete
 //+kubebuilder:rbac:groups=snapshot.storage.k8s.io,resources=volumesnapshots,verbs=get;list;watch
+//+kubebuilder:rbac:groups=apiextensions.k8s.io,resources=customresourcedefinitions,verbs=get
 
 func (r *ReplicationGroupSourceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
 	logger := log.FromContext(ctx)

controllers/util/cephfs_cg.go

@@ -11,12 +11,14 @@ import (
 	ramendrv1alpha1 "github.com/ramendr/ramen/api/v1alpha1"
 	corev1 "k8s.io/api/core/v1"
 	storagev1 "k8s.io/api/storage/v1"
+	apiextensionsv1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1"
 	"k8s.io/apimachinery/pkg/api/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/labels"
 	"k8s.io/apimachinery/pkg/types"
 	"k8s.io/client-go/util/retry"
 	"sigs.k8s.io/controller-runtime/pkg/client"
+	"sigs.k8s.io/controller-runtime/pkg/manager"
 )
 
 const (
@@ -26,6 +28,27 @@ const (
 	RGSOwnerLabel         string = "ramendr.openshift.io/rgs"
 )
 
+func IsFSCGSupport(mgr manager.Manager) (bool, error) {
+	k8sClient, err := client.New(mgr.GetConfig(), client.Options{Scheme: mgr.GetScheme()})
+	if err != nil {
+		return false, err
+	}
+
+	vgsCRD := &apiextensionsv1.CustomResourceDefinition{}
+	if err := k8sClient.Get(context.Background(),
+		types.NamespacedName{Name: "volumegroupsnapshots.groupsnapshot.storage.k8s.io"},
+		vgsCRD,
+	); err != nil {
+		if errors.IsNotFound(err) {
+			return false, nil
+		}
+
+		return false, err
+	}
+
+	return true, nil
+}
+
 func GetPVCLatestImageRGD(
 	pvcname string, rgd ramendrv1alpha1.ReplicationGroupDestination,
 ) *corev1.TypedLocalObjectReference {

main.go

@@ -39,6 +39,7 @@ import (
 	argocdv1alpha1hack "github.com/ramendr/ramen/controllers/argocd"
 	rmnutil "github.com/ramendr/ramen/controllers/util"
 	recipe "github.com/ramendr/recipe/api/v1alpha1"
+	apiextensionsv1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1"
 	// +kubebuilder:scaffold:imports
 )
 
@@ -113,6 +114,7 @@ func configureController(ramenConfig *ramendrv1alpha1.RamenConfig) error {
 		utilruntime.Must(snapv1.AddToScheme(scheme))
 		utilruntime.Must(groupsnapv1alpha1.AddToScheme(scheme))
 		utilruntime.Must(recipe.AddToScheme(scheme))
+		utilruntime.Must(apiextensionsv1.AddToScheme(scheme))
 	}
 
 	return nil
@@ -165,20 +167,28 @@ func setupReconcilersCluster(mgr ctrl.Manager, ramenConfig *ramendrv1alpha1.Rame
 		os.Exit(1)
 	}
 
-	if err := (&controllers.ReplicationGroupDestinationReconciler{
-		Client: mgr.GetClient(),
-		Scheme: mgr.GetScheme(),
-	}).SetupWithManager(mgr); err != nil {
-		setupLog.Error(err, "unable to create controller", "controller", "ReplicationGroupDestination")
+	fsCGSupport, err := rmnutil.IsFSCGSupport(mgr)
+	if err != nil {
+		setupLog.Error(err, "failed to check if ceph fs consistency group is supported")
 		os.Exit(1)
 	}
 
-	if err := (&controllers.ReplicationGroupSourceReconciler{
-		Client: mgr.GetClient(),
-		Scheme: mgr.GetScheme(),
-	}).SetupWithManager(mgr); err != nil {
-		setupLog.Error(err, "unable to create controller", "controller", "ReplicationGroupSource")
-		os.Exit(1)
+	if fsCGSupport {
+		if err := (&controllers.ReplicationGroupDestinationReconciler{
+			Client: mgr.GetClient(),
+			Scheme: mgr.GetScheme(),
+		}).SetupWithManager(mgr); err != nil {
+			setupLog.Error(err, "unable to create controller", "controller", "ReplicationGroupDestination")
+			os.Exit(1)
+		}
+
+		if err := (&controllers.ReplicationGroupSourceReconciler{
+			Client: mgr.GetClient(),
+			Scheme: mgr.GetScheme(),
+		}).SetupWithManager(mgr); err != nil {
+			setupLog.Error(err, "unable to create controller", "controller", "ReplicationGroupSource")
+			os.Exit(1)
+		}
 	}
 }