Wrap all error (#1061)

jiuker · guozhi.li · web-flow · commit 6d5295b4858c · 2022-06-13T09:28:40.000Z
* wrap error。

Co-authored-by: guozhi.li &lt;guozhi.li@daocloud.io&gt;
diff --git a/controllers/reconcile_cli.go b/controllers/reconcile_cli.go
@@ -74,7 +74,7 @@ func (r *RabbitmqClusterReconciler) runEnableFeatureFlagsCommand(ctx context.Con
 		msg := "failed to enable all feature flags on pod"
 		logger.Error(err, msg, "pod", podName, "command", cmd, "stdout", stdout, "stderr", stderr)
 		r.Recorder.Event(rmq, corev1.EventTypeWarning, "FailedReconcile", fmt.Sprintf("%s %s", msg, podName))
-		return fmt.Errorf("%s %s: %v", msg, podName, err)
+		return fmt.Errorf("%s %s: %w", msg, podName, err)
 	}
 	logger.Info("successfully enabled all feature flags")
 	return r.deleteAnnotation(ctx, sts, stsCreateAnnotation)
@@ -95,7 +95,7 @@ func (r *RabbitmqClusterReconciler) runSetPluginsCommand(ctx context.Context, rm
 			msg := "failed to set plugins on pod"
 			logger.Error(err, msg, "pod", podName, "command", cmd, "stdout", stdout, "stderr", stderr)
 			r.Recorder.Event(rmq, corev1.EventTypeWarning, "FailedReconcile", fmt.Sprintf("%s %s", msg, podName))
-			return fmt.Errorf("%s %s: %v", msg, podName, err)
+			return fmt.Errorf("%s %s: %w", msg, podName, err)
 		}
 	}
 	logger.Info("successfully set plugins")
@@ -111,7 +111,7 @@ func (r *RabbitmqClusterReconciler) runQueueRebalanceCommand(ctx context.Context
 		msg := "failed to run queue rebalance on pod"
 		logger.Error(err, msg, "pod", podName, "command", cmd, "stdout", stdout, "stderr", stderr)
 		r.Recorder.Event(rmq, corev1.EventTypeWarning, "FailedReconcile", fmt.Sprintf("%s %s", msg, podName))
-		return fmt.Errorf("%s %s: %v", msg, podName, err)
+		return fmt.Errorf("%s %s: %w", msg, podName, err)
 	}
 	return r.deleteAnnotation(ctx, rmq, queueRebalanceAnnotation)
 }
diff --git a/controllers/reconcile_finalizer.go b/controllers/reconcile_finalizer.go
@@ -53,15 +53,15 @@ func (r *RabbitmqClusterReconciler) prepareForDeletion(ctx context.Context, rabb
 			}
 			// Add label on all Pods to be picked up in pre-stop hook via Downward API
 			if err := r.addRabbitmqDeletionLabel(ctx, rabbitmqCluster); err != nil {
-				return fmt.Errorf("failed to add deletion markers to RabbitmqCluster Pods: %s", err.Error())
+				return fmt.Errorf("failed to add deletion markers to RabbitmqCluster Pods: %w", err)
 			}
 			// Delete StatefulSet immediately after changing pod labels to minimize risk of them respawning.
 			// There is a window where the StatefulSet could respawn Pods without the deletion label in this order.
 			// But we can't delete it before because the DownwardAPI doesn't update once a Pod enters Terminating.
 			// Addressing #648: if both rabbitmqCluster and the statefulSet returned by r.Get() are stale (and match each other),
 			// setting the stale statefulSet's uid in the precondition can avoid mis-deleting any currently running statefulSet sharing the same name.
 			if err := r.Client.Delete(ctx, sts, &client.DeleteOptions{Preconditions: &metav1.Preconditions{UID: &uid}}); client.IgnoreNotFound(err) != nil {
-				return fmt.Errorf("cannot delete StatefulSet: %s", err.Error())
+				return fmt.Errorf("cannot delete StatefulSet: %w", err)
 			}
 
 			return nil
@@ -95,7 +95,7 @@ func (r *RabbitmqClusterReconciler) addRabbitmqDeletionLabel(ctx context.Context
 		pod := &pods.Items[i]
 		pod.Labels[resource.DeletionMarker] = "true"
 		if err := r.Client.Update(ctx, pod); client.IgnoreNotFound(err) != nil {
-			return fmt.Errorf("cannot Update Pod %s in Namespace %s: %s", pod.Name, pod.Namespace, err.Error())
+			return fmt.Errorf("cannot Update Pod %s in Namespace %s: %w", pod.Name, pod.Namespace, err)
 		}
 	}
 
diff --git a/controllers/utils.go b/controllers/utils.go
@@ -73,7 +73,7 @@ func (r *RabbitmqClusterReconciler) statefulSetUID(ctx context.Context, rmq *rab
 	var sts *appsv1.StatefulSet
 	var ref *metav1.OwnerReference
 	if sts, err = r.statefulSet(ctx, rmq); err != nil {
-		return "", fmt.Errorf("failed to get statefulSet: %s", err.Error())
+		return "", fmt.Errorf("failed to get statefulSet: %w", err)
 	}
 	if ref = metav1.GetControllerOf(sts); ref == nil {
 		return "", fmt.Errorf("failed to get controller reference for statefulSet %s", sts.GetName())
diff --git a/internal/resource/configmap.go b/internal/resource/configmap.go
@@ -240,7 +240,7 @@ func (builder *ServerConfigMapBuilder) Update(object client.Object) error {
 	updateProperty(configMap.Data, "rabbitmq-env.conf", rmqProperties.EnvConfig)
 
 	if err := controllerutil.SetControllerReference(builder.Instance, configMap, builder.Scheme); err != nil {
-		return fmt.Errorf("failed setting controller reference: %v", err)
+		return fmt.Errorf("failed setting controller reference: %w", err)
 	}
 
 	return nil
diff --git a/internal/resource/default_user_secret.go b/internal/resource/default_user_secret.go
@@ -89,7 +89,7 @@ func (builder *DefaultUserSecretBuilder) Update(object client.Object) error {
 	builder.updatePorts(secret)
 
 	if err := controllerutil.SetControllerReference(builder.Instance, secret, builder.Scheme); err != nil {
-		return fmt.Errorf("failed setting controller reference: %v", err)
+		return fmt.Errorf("failed setting controller reference: %w", err)
 	}
 
 	return nil
diff --git a/internal/resource/erlang_cookie.go b/internal/resource/erlang_cookie.go
@@ -62,7 +62,7 @@ func (builder *ErlangCookieBuilder) Update(object client.Object) error {
 	secret.Annotations = metadata.ReconcileAndFilterAnnotations(secret.GetAnnotations(), builder.Instance.Annotations)
 
 	if err := controllerutil.SetControllerReference(builder.Instance, secret, builder.Scheme); err != nil {
-		return fmt.Errorf("failed setting controller reference: %v", err)
+		return fmt.Errorf("failed setting controller reference: %w", err)
 	}
 
 	return nil
diff --git a/internal/resource/headless_service.go b/internal/resource/headless_service.go
@@ -73,7 +73,7 @@ func (builder *HeadlessServiceBuilder) Update(object client.Object) error {
 	}
 
 	if err := controllerutil.SetControllerReference(builder.Instance, service, builder.Scheme); err != nil {
-		return fmt.Errorf("failed setting controller reference: %v", err)
+		return fmt.Errorf("failed setting controller reference: %w", err)
 	}
 
 	return nil
diff --git a/internal/resource/rabbitmq_plugins.go b/internal/resource/rabbitmq_plugins.go
@@ -57,7 +57,7 @@ func (builder *RabbitmqPluginsConfigMapBuilder) Update(object client.Object) err
 	configMap.Data["enabled_plugins"] = desiredPluginsAsString(builder.Instance.Spec.Rabbitmq.AdditionalPlugins)
 
 	if err := controllerutil.SetControllerReference(builder.Instance, configMap, builder.Scheme); err != nil {
-		return fmt.Errorf("failed setting controller reference: %v", err)
+		return fmt.Errorf("failed setting controller reference: %w", err)
 	}
 	return nil
 }
diff --git a/internal/resource/role.go b/internal/resource/role.go
@@ -63,7 +63,7 @@ func (builder *RoleBuilder) Update(object client.Object) error {
 	}
 
 	if err := controllerutil.SetControllerReference(builder.Instance, role, builder.Scheme); err != nil {
-		return fmt.Errorf("failed setting controller reference: %v", err)
+		return fmt.Errorf("failed setting controller reference: %w", err)
 	}
 	return nil
 }
diff --git a/internal/resource/role_binding.go b/internal/resource/role_binding.go
@@ -53,7 +53,7 @@ func (builder *RoleBindingBuilder) Update(object client.Object) error {
 	}
 
 	if err := controllerutil.SetControllerReference(builder.Instance, roleBinding, builder.Scheme); err != nil {
-		return fmt.Errorf("failed setting controller reference: %v", err)
+		return fmt.Errorf("failed setting controller reference: %w", err)
 	}
 	return nil
 }
diff --git a/internal/resource/service.go b/internal/resource/service.go
@@ -69,12 +69,12 @@ func (builder *ServiceBuilder) Update(object client.Object) error {
 
 	if builder.Instance.Spec.Override.Service != nil {
 		if err := applySvcOverride(service, builder.Instance.Spec.Override.Service); err != nil {
-			return fmt.Errorf("failed applying Service override: %v", err)
+			return fmt.Errorf("failed applying Service override: %w", err)
 		}
 	}
 
 	if err := controllerutil.SetControllerReference(builder.Instance, service, builder.Scheme); err != nil {
-		return fmt.Errorf("failed setting controller reference: %v", err)
+		return fmt.Errorf("failed setting controller reference: %w", err)
 	}
 
 	return nil
@@ -88,23 +88,23 @@ func applySvcOverride(svc *corev1.Service, override *rabbitmqv1beta1.Service) er
 	if override.Spec != nil {
 		originalSvcSpec, err := json.Marshal(svc.Spec)
 		if err != nil {
-			return fmt.Errorf("error marshalling Service Spec: %v", err)
+			return fmt.Errorf("error marshalling Service Spec: %w", err)
 		}
 
 		patch, err := json.Marshal(override.Spec)
 		if err != nil {
-			return fmt.Errorf("error marshalling Service Spec override: %v", err)
+			return fmt.Errorf("error marshalling Service Spec override: %w", err)
 		}
 
 		patchedJSON, err := strategicpatch.StrategicMergePatch(originalSvcSpec, patch, corev1.ServiceSpec{})
 		if err != nil {
-			return fmt.Errorf("error patching Service Spec: %v", err)
+			return fmt.Errorf("error patching Service Spec: %w", err)
 		}
 
 		patchedSvcSpec := corev1.ServiceSpec{}
 		err = json.Unmarshal(patchedJSON, &patchedSvcSpec)
 		if err != nil {
-			return fmt.Errorf("error unmarshalling patched Service Spec: %v", err)
+			return fmt.Errorf("error unmarshalling patched Service Spec: %w", err)
 		}
 		svc.Spec = patchedSvcSpec
 	}
diff --git a/internal/resource/service_account.go b/internal/resource/service_account.go
@@ -51,7 +51,7 @@ func (builder *ServiceAccountBuilder) Update(object client.Object) error {
 	serviceAccount.Annotations = metadata.ReconcileAndFilterAnnotations(serviceAccount.GetAnnotations(), builder.Instance.Annotations)
 
 	if err := controllerutil.SetControllerReference(builder.Instance, serviceAccount, builder.Scheme); err != nil {
-		return fmt.Errorf("failed setting controller reference: %v", err)
+		return fmt.Errorf("failed setting controller reference: %w", err)
 	}
 	return nil
 }
diff --git a/internal/resource/statefulset.go b/internal/resource/statefulset.go
@@ -125,12 +125,12 @@ func (builder *StatefulSetBuilder) Update(object client.Object) error {
 
 	if builder.Instance.Spec.Override.StatefulSet != nil {
 		if err := applyStsOverride(builder.Instance, builder.Scheme, sts, builder.Instance.Spec.Override.StatefulSet); err != nil {
-			return fmt.Errorf("failed applying StatefulSet override: %v", err)
+			return fmt.Errorf("failed applying StatefulSet override: %w", err)
 		}
 	}
 
 	if err := controllerutil.SetControllerReference(builder.Instance, sts, builder.Scheme); err != nil {
-		return fmt.Errorf("failed setting controller reference: %v", err)
+		return fmt.Errorf("failed setting controller reference: %w", err)
 	}
 	return nil
 }
@@ -177,7 +177,7 @@ func applyStsOverride(instance *rabbitmqv1beta1.RabbitmqCluster, scheme *runtime
 				pvcOverride[i].Namespace = sts.Namespace // PVC should always be in the same namespace as the Stateful Set
 				pvcOverride[i].Spec = volumeClaimTemplatesOverride[i].Spec
 				if err := controllerutil.SetControllerReference(instance, &pvcOverride[i], scheme); err != nil {
-					return fmt.Errorf("failed setting controller reference: %v", err)
+					return fmt.Errorf("failed setting controller reference: %w", err)
 				}
 				disableBlockOwnerDeletion(pvcOverride[i])
 			}
@@ -227,7 +227,7 @@ func persistentVolumeClaim(instance *rabbitmqv1beta1.RabbitmqCluster, scheme *ru
 	}
 
 	if err := controllerutil.SetControllerReference(instance, &pvc, scheme); err != nil {
-		return []corev1.PersistentVolumeClaim{}, fmt.Errorf("failed setting controller reference: %v", err)
+		return []corev1.PersistentVolumeClaim{}, fmt.Errorf("failed setting controller reference: %w", err)
 	}
 	disableBlockOwnerDeletion(pvc)
 
@@ -245,23 +245,23 @@ func disableBlockOwnerDeletion(pvc corev1.PersistentVolumeClaim) {
 func patchPodSpec(podSpec, podSpecOverride *corev1.PodSpec) (corev1.PodSpec, error) {
 	originalPodSpec, err := json.Marshal(podSpec)
 	if err != nil {
-		return corev1.PodSpec{}, fmt.Errorf("error marshalling statefulSet podSpec: %v", err)
+		return corev1.PodSpec{}, fmt.Errorf("error marshalling statefulSet podSpec: %w", err)
 	}
 
 	patch, err := json.Marshal(podSpecOverride)
 	if err != nil {
-		return corev1.PodSpec{}, fmt.Errorf("error marshalling statefulSet podSpec override: %v", err)
+		return corev1.PodSpec{}, fmt.Errorf("error marshalling statefulSet podSpec override: %w", err)
 	}
 
 	patchedJSON, err := strategicpatch.StrategicMergePatch(originalPodSpec, patch, corev1.PodSpec{})
 	if err != nil {
-		return corev1.PodSpec{}, fmt.Errorf("error patching podSpec: %v", err)
+		return corev1.PodSpec{}, fmt.Errorf("error patching podSpec: %w", err)
 	}
 
 	patchedPodSpec := corev1.PodSpec{}
 	err = json.Unmarshal(patchedJSON, &patchedPodSpec)
 	if err != nil {
-		return corev1.PodSpec{}, fmt.Errorf("error unmarshalling patched Stateful Set: %v", err)
+		return corev1.PodSpec{}, fmt.Errorf("error unmarshalling patched Stateful Set: %w", err)
 	}
 
 	rmqContainer := containerRabbitmq(podSpecOverride.Containers)
diff --git a/system_tests/utils.go b/system_tests/utils.go
@@ -116,7 +116,7 @@ func makeRequest(url, httpMethod, rabbitmqUsername, rabbitmqPassword string, bod
 	resp, err := client.Do(req)
 	if err != nil {
 		fmt.Printf("Failed to make api request to url %s with err: %+v \n", url, err)
-		return responseBody, fmt.Errorf("failed with err: %v to api endpoint: %s", err, url)
+		return responseBody, fmt.Errorf("failed with err: %w to api endpoint: %s", err, url)
 	}
 	defer resp.Body.Close()
 	responseBody, err = ioutil.ReadAll(resp.Body)
@@ -753,7 +753,7 @@ func k8sCreateTLSSecret(secretName, secretNamespace, certPath, keyPath string) e
 	)
 
 	if err != nil {
-		return fmt.Errorf("Failed with error: %v\nOutput: %v\n", err.Error(), string(output))
+		return fmt.Errorf("Failed with error: %w\nOutput: %v\n", err, string(output))
 	}
 
 	return nil
@@ -769,7 +769,7 @@ func k8sDeleteSecret(secretName, secretNamespace string) error {
 	)
 
 	if err != nil {
-		return fmt.Errorf("Failed with error: %v\nOutput: %v\n", err.Error(), string(output))
+		return fmt.Errorf("Failed with error: %w\nOutput: %v\n", err, string(output))
 	}
 
 	return nil

Original file line number	Diff line number	Diff line change
`@@ -74,7 +74,7 @@ func (r *RabbitmqClusterReconciler) runEnableFeatureFlagsCommand(ctx context.Con`
`74`	`74`	`msg := "failed to enable all feature flags on pod"`
`75`	`75`	`logger.Error(err, msg, "pod", podName, "command", cmd, "stdout", stdout, "stderr", stderr)`
`76`	`76`	`r.Recorder.Event(rmq, corev1.EventTypeWarning, "FailedReconcile", fmt.Sprintf("%s %s", msg, podName))`
`77`		`- return fmt.Errorf("%s %s: %v", msg, podName, err)`
	`77`	`+ return fmt.Errorf("%s %s: %w", msg, podName, err)`
`78`	`78`	`}`
`79`	`79`	`logger.Info("successfully enabled all feature flags")`
`80`	`80`	`return r.deleteAnnotation(ctx, sts, stsCreateAnnotation)`
`@@ -95,7 +95,7 @@ func (r *RabbitmqClusterReconciler) runSetPluginsCommand(ctx context.Context, rm`
`95`	`95`	`msg := "failed to set plugins on pod"`
`96`	`96`	`logger.Error(err, msg, "pod", podName, "command", cmd, "stdout", stdout, "stderr", stderr)`
`97`	`97`	`r.Recorder.Event(rmq, corev1.EventTypeWarning, "FailedReconcile", fmt.Sprintf("%s %s", msg, podName))`
`98`		`- return fmt.Errorf("%s %s: %v", msg, podName, err)`
	`98`	`+ return fmt.Errorf("%s %s: %w", msg, podName, err)`
`99`	`99`	`}`
`100`	`100`	`}`
`101`	`101`	`logger.Info("successfully set plugins")`
`@@ -111,7 +111,7 @@ func (r *RabbitmqClusterReconciler) runQueueRebalanceCommand(ctx context.Context`
`111`	`111`	`msg := "failed to run queue rebalance on pod"`
`112`	`112`	`logger.Error(err, msg, "pod", podName, "command", cmd, "stdout", stdout, "stderr", stderr)`
`113`	`113`	`r.Recorder.Event(rmq, corev1.EventTypeWarning, "FailedReconcile", fmt.Sprintf("%s %s", msg, podName))`
`114`		`- return fmt.Errorf("%s %s: %v", msg, podName, err)`
	`114`	`+ return fmt.Errorf("%s %s: %w", msg, podName, err)`
`115`	`115`	`}`
`116`	`116`	`return r.deleteAnnotation(ctx, rmq, queueRebalanceAnnotation)`
`117`	`117`	`}`
Original file line number	Diff line number	Diff line change
`@@ -53,15 +53,15 @@ func (r *RabbitmqClusterReconciler) prepareForDeletion(ctx context.Context, rabb`
`53`	`53`	`}`
`54`	`54`	`// Add label on all Pods to be picked up in pre-stop hook via Downward API`
`55`	`55`	`if err := r.addRabbitmqDeletionLabel(ctx, rabbitmqCluster); err != nil {`
`56`		`- return fmt.Errorf("failed to add deletion markers to RabbitmqCluster Pods: %s", err.Error())`
	`56`	`+ return fmt.Errorf("failed to add deletion markers to RabbitmqCluster Pods: %w", err)`
`57`	`57`	`}`
`58`	`58`	`// Delete StatefulSet immediately after changing pod labels to minimize risk of them respawning.`
`59`	`59`	`// There is a window where the StatefulSet could respawn Pods without the deletion label in this order.`
`60`	`60`	`// But we can't delete it before because the DownwardAPI doesn't update once a Pod enters Terminating.`
`61`	`61`	`// Addressing #648: if both rabbitmqCluster and the statefulSet returned by r.Get() are stale (and match each other),`
`62`	`62`	`// setting the stale statefulSet's uid in the precondition can avoid mis-deleting any currently running statefulSet sharing the same name.`
`63`	`63`	`if err := r.Client.Delete(ctx, sts, &client.DeleteOptions{Preconditions: &metav1.Preconditions{UID: &uid}}); client.IgnoreNotFound(err) != nil {`
`64`		`- return fmt.Errorf("cannot delete StatefulSet: %s", err.Error())`
	`64`	`+ return fmt.Errorf("cannot delete StatefulSet: %w", err)`
`65`	`65`	`}`
`66`	`66`
`67`	`67`	`return nil`
`@@ -95,7 +95,7 @@ func (r *RabbitmqClusterReconciler) addRabbitmqDeletionLabel(ctx context.Context`
`95`	`95`	`pod := &pods.Items[i]`
`96`	`96`	`pod.Labels[resource.DeletionMarker] = "true"`
`97`	`97`	`if err := r.Client.Update(ctx, pod); client.IgnoreNotFound(err) != nil {`
`98`		`- return fmt.Errorf("cannot Update Pod %s in Namespace %s: %s", pod.Name, pod.Namespace, err.Error())`
	`98`	`+ return fmt.Errorf("cannot Update Pod %s in Namespace %s: %w", pod.Name, pod.Namespace, err)`
`99`	`99`	`}`
`100`	`100`	`}`
`101`	`101`
Original file line number	Diff line number	Diff line change
`@@ -73,7 +73,7 @@ func (r RabbitmqClusterReconciler) statefulSetUID(ctx context.Context, rmq rab`
`73`	`73`	`var sts *appsv1.StatefulSet`
`74`	`74`	`var ref *metav1.OwnerReference`
`75`	`75`	`if sts, err = r.statefulSet(ctx, rmq); err != nil {`
`76`		`- return "", fmt.Errorf("failed to get statefulSet: %s", err.Error())`
	`76`	`+ return "", fmt.Errorf("failed to get statefulSet: %w", err)`
`77`	`77`	`}`
`78`	`78`	`if ref = metav1.GetControllerOf(sts); ref == nil {`
`79`	`79`	`return "", fmt.Errorf("failed to get controller reference for statefulSet %s", sts.GetName())`
Original file line number	Diff line number	Diff line change
`@@ -240,7 +240,7 @@ func (builder *ServerConfigMapBuilder) Update(object client.Object) error {`
`240`	`240`	`updateProperty(configMap.Data, "rabbitmq-env.conf", rmqProperties.EnvConfig)`
`241`	`241`
`242`	`242`	`if err := controllerutil.SetControllerReference(builder.Instance, configMap, builder.Scheme); err != nil {`
`243`		`- return fmt.Errorf("failed setting controller reference: %v", err)`
	`243`	`+ return fmt.Errorf("failed setting controller reference: %w", err)`
`244`	`244`	`}`
`245`	`245`
`246`	`246`	`return nil`
Original file line number	Diff line number	Diff line change
`@@ -89,7 +89,7 @@ func (builder *DefaultUserSecretBuilder) Update(object client.Object) error {`
`89`	`89`	`builder.updatePorts(secret)`
`90`	`90`
`91`	`91`	`if err := controllerutil.SetControllerReference(builder.Instance, secret, builder.Scheme); err != nil {`
`92`		`- return fmt.Errorf("failed setting controller reference: %v", err)`
	`92`	`+ return fmt.Errorf("failed setting controller reference: %w", err)`
`93`	`93`	`}`
`94`	`94`
`95`	`95`	`return nil`
Original file line number	Diff line number	Diff line change
`@@ -62,7 +62,7 @@ func (builder *ErlangCookieBuilder) Update(object client.Object) error {`
`62`	`62`	`secret.Annotations = metadata.ReconcileAndFilterAnnotations(secret.GetAnnotations(), builder.Instance.Annotations)`
`63`	`63`
`64`	`64`	`if err := controllerutil.SetControllerReference(builder.Instance, secret, builder.Scheme); err != nil {`
`65`		`- return fmt.Errorf("failed setting controller reference: %v", err)`
	`65`	`+ return fmt.Errorf("failed setting controller reference: %w", err)`
`66`	`66`	`}`
`67`	`67`
`68`	`68`	`return nil`
Original file line number	Diff line number	Diff line change
`@@ -73,7 +73,7 @@ func (builder *HeadlessServiceBuilder) Update(object client.Object) error {`
`73`	`73`	`}`
`74`	`74`
`75`	`75`	`if err := controllerutil.SetControllerReference(builder.Instance, service, builder.Scheme); err != nil {`
`76`		`- return fmt.Errorf("failed setting controller reference: %v", err)`
	`76`	`+ return fmt.Errorf("failed setting controller reference: %w", err)`
`77`	`77`	`}`
`78`	`78`
`79`	`79`	`return nil`
Original file line number	Diff line number	Diff line change
`@@ -57,7 +57,7 @@ func (builder *RabbitmqPluginsConfigMapBuilder) Update(object client.Object) err`
`57`	`57`	`configMap.Data["enabled_plugins"] = desiredPluginsAsString(builder.Instance.Spec.Rabbitmq.AdditionalPlugins)`
`58`	`58`
`59`	`59`	`if err := controllerutil.SetControllerReference(builder.Instance, configMap, builder.Scheme); err != nil {`
`60`		`- return fmt.Errorf("failed setting controller reference: %v", err)`
	`60`	`+ return fmt.Errorf("failed setting controller reference: %w", err)`
`61`	`61`	`}`
`62`	`62`	`return nil`
`63`	`63`	`}`
Original file line number	Diff line number	Diff line change
`@@ -63,7 +63,7 @@ func (builder *RoleBuilder) Update(object client.Object) error {`
`63`	`63`	`}`
`64`	`64`
`65`	`65`	`if err := controllerutil.SetControllerReference(builder.Instance, role, builder.Scheme); err != nil {`
`66`		`- return fmt.Errorf("failed setting controller reference: %v", err)`
	`66`	`+ return fmt.Errorf("failed setting controller reference: %w", err)`
`67`	`67`	`}`
`68`	`68`	`return nil`
`69`	`69`	`}`
Original file line number	Diff line number	Diff line change
`@@ -53,7 +53,7 @@ func (builder *RoleBindingBuilder) Update(object client.Object) error {`
`53`	`53`	`}`
`54`	`54`
`55`	`55`	`if err := controllerutil.SetControllerReference(builder.Instance, roleBinding, builder.Scheme); err != nil {`
`56`		`- return fmt.Errorf("failed setting controller reference: %v", err)`
	`56`	`+ return fmt.Errorf("failed setting controller reference: %w", err)`
`57`	`57`	`}`
`58`	`58`	`return nil`
`59`	`59`	`}`