convert updateBindingRolloutStarted

Signed-off-by: Arvind Thirumurugan <arvindth@microsoft.com>

Author: Arvind Thirumurugan

pkg/controllers/updaterun/execution.go

@@ -400,22 +400,22 @@ func (r *Reconciler) checkAfterStageTasksStatus(ctx context.Context, updatingSta
 }
 
 // updateBindingRolloutStarted updates the binding status to indicate the rollout has started.
-func (r *Reconciler) updateBindingRolloutStarted(ctx context.Context, binding *placementv1beta1.ClusterResourceBinding, updateRun *placementv1beta1.ClusterStagedUpdateRun) error {
+func (r *Reconciler) updateBindingRolloutStarted(ctx context.Context, binding placementv1beta1.BindingObj, updateRun placementv1beta1.UpdateRunObj) error {
 	// first reset the condition to reflect the latest lastTransitionTime
 	binding.RemoveCondition(string(placementv1beta1.ResourceBindingRolloutStarted))
 	cond := metav1.Condition{
 		Type:               string(placementv1beta1.ResourceBindingRolloutStarted),
 		Status:             metav1.ConditionTrue,
-		ObservedGeneration: binding.Generation,
+		ObservedGeneration: binding.GetGeneration(),
 		Reason:             condition.RolloutStartedReason,
-		Message:            fmt.Sprintf("Detected the new changes on the resources and started the rollout process, resourceSnapshotIndex: %s, clusterStagedUpdateRun: %s", updateRun.Spec.ResourceSnapshotIndex, updateRun.Name),
+		Message:            fmt.Sprintf("Detected the new changes on the resources and started the rollout process, resourceSnapshotIndex: %s, updateRun: %s", updateRun.GetUpdateRunSpec().ResourceSnapshotIndex, updateRun.GetName()),
 	}
 	binding.SetConditions(cond)
 	if err := r.Client.Status().Update(ctx, binding); err != nil {
-		klog.ErrorS(err, "Failed to update binding status", "clusterResourceBinding", klog.KObj(binding), "condition", cond)
+		klog.ErrorS(err, "Failed to update binding status", "binding", klog.KObj(binding), "condition", cond)
 		return controller.NewUpdateIgnoreConflictError(err)
 	}
-	klog.V(2).InfoS("Updated binding as rolloutStarted", "clusterResourceBinding", klog.KObj(binding), "condition", cond)
+	klog.V(2).InfoS("Updated binding as rolloutStarted", "binding", klog.KObj(binding), "condition", cond)
 	return nil
 }