Add some logging for adoption functions

Signed-off-by: Shyamsundar Ranganathan <[email protected]>
(cherry picked from commit 01470b0)

Author: ShyamsundarR

controllers/drplacementcontrol_controller.go

@@ -2469,7 +2469,8 @@ func ensureVRGsManagedByDRPC(
 
 	for cluster, viewVRG := range vrgs {
 		if !viewVRG.GetDeletionTimestamp().IsZero() {
-			log.Info("VRG reported by view undergoing deletion, during adoption")
+			log.Info("VRG reported by view undergoing deletion, during adoption",
+				"cluster", cluster, "namespace", viewVRG.Namespace, "name", viewVRG.Name)
 
 			continue
 		}
@@ -2503,7 +2504,7 @@ func adoptVRG(
 	mw, err := mwu.FindManifestWorkByType(rmnutil.MWTypeVRG, cluster)
 	if err != nil {
 		if !errors.IsNotFound(err) {
-			log.Info("error fetching VRG ManifestWork during adoption", "error", err)
+			log.Info("error fetching VRG ManifestWork during adoption", "error", err, "cluster", cluster)
 
 			return !adopted
 		}
@@ -2514,14 +2515,14 @@ func adoptVRG(
 	}
 
 	if !mw.GetDeletionTimestamp().IsZero() {
-		log.Info("VRG ManifestWork found deleted during adoption")
+		log.Info("VRG ManifestWork found deleted during adoption", "cluster", cluster)
 
 		return adopted
 	}
 
 	vrg, err := rmnutil.ExtractVRGFromManifestWork(mw)
 	if err != nil {
-		log.Info("error extracting VRG from ManifestWork during adoption", "error", err)
+		log.Info("error extracting VRG from ManifestWork during adoption", "error", err, "cluster", cluster)
 
 		return !adopted
 	}
@@ -2541,12 +2542,17 @@ func adoptExistingVRGManifestWork(
 	drpc *rmn.DRPlacementControl,
 	vrgNamespace string,
 ) {
+	log.Info("adopting existing VRG ManifestWork", "cluster", cluster, "namespace", vrg.Namespace, "name", vrg.Name)
+
 	if vrg.GetAnnotations() == nil {
 		vrg.Annotations = make(map[string]string)
 	}
 
 	if v, ok := vrg.Annotations[DRPCUIDAnnotation]; ok && v == string(drpc.UID) {
 		// Annotation may already be set but not reflected on the resource view yet
+		log.Info("detected VRGs DRPC UID annotation as existing",
+			"cluster", cluster, "namespace", vrg.Namespace, "name", vrg.Name)
+
 		return
 	}
 
@@ -2558,7 +2564,7 @@ func adoptExistingVRGManifestWork(
 
 	err := mwu.CreateOrUpdateVRGManifestWork(drpc.Name, vrgNamespace, cluster, *vrg, annotations)
 	if err != nil {
-		log.Info("error updating VRG via ManifestWork during adoption", "error", err)
+		log.Info("error updating VRG via ManifestWork during adoption", "error", err, "cluster", cluster)
 	}
 }
 
@@ -2571,14 +2577,17 @@ func adoptOrphanVRG(
 	drpc *rmn.DRPlacementControl,
 	vrgNamespace string,
 ) {
+	log.Info("adopting orphaned VRG ManifestWork",
+		"cluster", cluster, "namespace", viewVRG.Namespace, "name", viewVRG.Name)
+
 	annotations := make(map[string]string)
 	annotations[DRPCNameAnnotation] = drpc.Name
 	annotations[DRPCNamespaceAnnotation] = drpc.Namespace
 
 	// Adopt the namespace as well
 	err := mwu.CreateOrUpdateNamespaceManifest(drpc.Name, vrgNamespace, cluster, annotations)
 	if err != nil {
-		log.Info("error creating namespace via ManifestWork during adoption", "error", err)
+		log.Info("error creating namespace via ManifestWork during adoption", "error", err, "cluster", cluster)
 
 		return
 	}
@@ -2593,7 +2602,7 @@ func adoptOrphanVRG(
 	if err := mwu.CreateOrUpdateVRGManifestWork(
 		drpc.Name, vrgNamespace,
 		cluster, *vrg, annotations); err != nil {
-		log.Info("error creating VRG via ManifestWork during adoption", "error", err)
+		log.Info("error creating VRG via ManifestWork during adoption", "error", err, "cluster", cluster)
 	}
 }