@@ -459,13 +459,13 @@ func (r *RabbitmqClusterReconciler) prepareForDeletion(ctx context.Context, rabb
459459 }
460460 // Add label on all Pods to be picked up in pre-stop hook via Downward API
461461 if err := r .addRabbitmqDeletionLabel (ctx , rabbitmqCluster ); err != nil {
462- return fmt .Errorf ("Failed to add deletion markers to RabbitmqCluster Pods: %s" , err .Error ())
462+ return fmt .Errorf ("failed to add deletion markers to RabbitmqCluster Pods: %s" , err .Error ())
463463 }
464464 // Delete StatefulSet immediately after changing pod labels to minimize risk of them respawning.
465465 // There is a window where the StatefulSet could respawn Pods without the deletion label in this order.
466466 // But we can't delete it before because the DownwardAPI doesn't update once a Pod enters Terminating.
467467 if err := r .Client .Delete (ctx , sts ); client .IgnoreNotFound (err ) != nil {
468- return fmt .Errorf ("Cannot delete StatefulSet: %s" , err .Error ())
468+ return fmt .Errorf ("cannot delete StatefulSet: %s" , err .Error ())
469469 }
470470
471471 return nil
@@ -508,7 +508,7 @@ func (r *RabbitmqClusterReconciler) addRabbitmqDeletionLabel(ctx context.Context
508508 pod := & pods .Items [i ]
509509 pod .Labels [resource .DeletionMarker ] = "true"
510510 if err := r .Client .Update (ctx , pod ); client .IgnoreNotFound (err ) != nil {
511- return fmt .Errorf ("Cannot Update Pod %s in Namespace %s: %s" , pod .Name , pod .Namespace , err .Error ())
511+ return fmt .Errorf ("cannot Update Pod %s in Namespace %s: %s" , pod .Name , pod .Namespace , err .Error ())
512512 }
513513 }
514514
0 commit comments