Function updateOwnerReference

controllers/parameters/parameter_util.go:300–327

(reqCtx intctrlutil.RequestCtx, cli client.Client, cluster *appsv1.Cluster, parameter *parametersv1alpha1.Parameter)

}

func updateOwnerReference(reqCtx intctrlutil.RequestCtx, cli client.Client, cluster *appsv1.Cluster, parameter *parametersv1alpha1.Parameter) (*ctrl.Result, error) {
	hasValidateOwnershop := func(obj client.Object) bool {
		// Check if the `parameter` object has a controller reference(Operation CR) or if the `cluster` is its owner.
		// If neither condition is true, attempt to set the `cluster` as the owner of the `parameter`.
		// This ensures proper ownership and garbage collection behavior in Kubernetes.
		return controllerutil.HasControllerReference(obj) || model.IsOwnerOf(cluster, obj)
	}

	clusterName := parameter.Labels[constant.AppInstanceLabelKey]
	if clusterName == parameter.Spec.ClusterName && hasValidateOwnershop(parameter) {
		return nil, nil
	}

	patch := client.MergeFrom(parameter.DeepCopy())
	if parameter.Labels == nil {
		parameter.Labels = make(map[string]string)
	}
	if !hasValidateOwnershop(parameter) {
		if err := intctrlutil.SetOwnerReference(cluster, parameter); err != nil {
			return intctrlutil.ResultToP(intctrlutil.CheckedRequeueWithError(err, reqCtx.Log, ""))
		}
	}
	parameter.Labels[constant.AppInstanceLabelKey] = parameter.Spec.ClusterName
	if err := cli.Patch(reqCtx.Ctx, parameter, patch); err != nil {
		return intctrlutil.ResultToP(intctrlutil.CheckedRequeueWithError(err, reqCtx.Log, ""))
	}
	return intctrlutil.ResultToP(intctrlutil.Reconciled())
}