Merge pull request #1670 from openshift-cherrypick-robot/cherry-pick-…

…1661-to-release-4.11

Bug 2083993: [release-4.11] ocs-to-ocs: create/delete subvolumegroup in consumer side

controllers/storageclassclaim/storageclassclaim_controller.go

@@ -291,6 +291,24 @@ func (r *StorageClassClaimReconciler) reconcileConsumerPhases() (reconcile.Resul
 				if err != nil {
 					return reconcile.Result{}, fmt.Errorf("failed to create or update secret %v: %s", secret, err)
 				}
+			case "CephFilesystemSubVolumeGroup":
+				subVolumeGroup := &rookCephv1.CephFilesystemSubVolumeGroup{ObjectMeta: metav1.ObjectMeta{
+					Name:      resource.Name,
+					Namespace: r.storageClassClaim.Namespace,
+				}}
+				_, err = ctrl.CreateOrUpdate(context.TODO(), r.Client, subVolumeGroup, func() error {
+					if err := r.own(subVolumeGroup); err != nil {
+						return err
+					}
+					subVolumeGroup.Spec = rookCephv1.CephFilesystemSubVolumeGroupSpec{
+						FilesystemName: data["filesystemName"],
+					}
+					return nil
+				})
+				if err != nil {
+					r.log.Error(err, "Could not create CephFilesystemSubVolumeGroup.", "CephFilesystemSubVolumeGroup", klog.KRef(subVolumeGroup.Namespace, subVolumeGroup.Name))
+					return reconcile.Result{}, err
+				}
 			case "StorageClass":
 				var storageClass *storagev1.StorageClass
 				data["csi.storage.k8s.io/provisioner-secret-namespace"] = r.storageClassClaim.Namespace