@@ -582,7 +582,7 @@ func (r *PerconaServerMySQLHibernationReconciler) pauseCluster(ctx context.Conte
582582 return k8sretry .RetryOnConflict (k8sretry .DefaultRetry , func () error {
583583 // Get fresh copy of the cluster
584584 fresh := & apiv1.PerconaServerMySQL {}
585- if err := r .Client . Get (ctx , types.NamespacedName {Name : cr .Name , Namespace : cr .Namespace }, fresh ); err != nil {
585+ if err := r .Get (ctx , types.NamespacedName {Name : cr .Name , Namespace : cr .Namespace }, fresh ); err != nil {
586586 log .Error (err , "Failed to get fresh cluster copy" , "cluster" , cr .Name , "namespace" , cr .Namespace )
587587 return err
588588 }
@@ -591,7 +591,7 @@ func (r *PerconaServerMySQLHibernationReconciler) pauseCluster(ctx context.Conte
591591 fresh .Spec .Pause = true
592592
593593 // Update the cluster
594- if err := r .Client . Update (ctx , fresh ); err != nil {
594+ if err := r .Update (ctx , fresh ); err != nil {
595595 log .Error (err , "Failed to update cluster spec" , "cluster" , cr .Name , "namespace" , cr .Namespace )
596596 return err
597597 }
@@ -632,7 +632,7 @@ func (r *PerconaServerMySQLHibernationReconciler) unpauseCluster(ctx context.Con
632632 return k8sretry .RetryOnConflict (k8sretry .DefaultRetry , func () error {
633633 // Get fresh copy of the cluster
634634 fresh := & apiv1.PerconaServerMySQL {}
635- if err := r .Client . Get (ctx , types.NamespacedName {Name : cr .Name , Namespace : cr .Namespace }, fresh ); err != nil {
635+ if err := r .Get (ctx , types.NamespacedName {Name : cr .Name , Namespace : cr .Namespace }, fresh ); err != nil {
636636 log .Error (err , "Failed to get fresh cluster copy" , "cluster" , cr .Name , "namespace" , cr .Namespace )
637637 return err
638638 }
@@ -641,7 +641,7 @@ func (r *PerconaServerMySQLHibernationReconciler) unpauseCluster(ctx context.Con
641641 fresh .Spec .Pause = false
642642
643643 // Update the cluster
644- if err := r .Client . Update (ctx , fresh ); err != nil {
644+ if err := r .Update (ctx , fresh ); err != nil {
645645 log .Error (err , "Failed to update cluster spec" , "cluster" , cr .Name , "namespace" , cr .Namespace )
646646 return err
647647 }
@@ -682,7 +682,7 @@ func (r *PerconaServerMySQLHibernationReconciler) updateHibernationState(ctx con
682682 return k8sretry .RetryOnConflict (k8sretry .DefaultRetry , func () error {
683683 // Get fresh copy of the cluster
684684 fresh := & apiv1.PerconaServerMySQL {}
685- if err := r .Client . Get (ctx , types.NamespacedName {Name : cr .Name , Namespace : cr .Namespace }, fresh ); err != nil {
685+ if err := r .Get (ctx , types.NamespacedName {Name : cr .Name , Namespace : cr .Namespace }, fresh ); err != nil {
686686 log .Error (err , "Failed to get fresh cluster copy for status update" , "cluster" , cr .Name , "namespace" , cr .Namespace )
687687 return err
688688 }
@@ -725,7 +725,7 @@ func (r *PerconaServerMySQLHibernationReconciler) initializeHibernationStatus(ct
725725 return k8sretry .RetryOnConflict (k8sretry .DefaultRetry , func () error {
726726 // Get fresh copy of the cluster
727727 fresh := & apiv1.PerconaServerMySQL {}
728- if err := r .Client . Get (ctx , types.NamespacedName {Name : cr .Name , Namespace : cr .Namespace }, fresh ); err != nil {
728+ if err := r .Get (ctx , types.NamespacedName {Name : cr .Name , Namespace : cr .Namespace }, fresh ); err != nil {
729729 log .Error (err , "Failed to get fresh cluster copy for status initialization" , "cluster" , cr .Name , "namespace" , cr .Namespace )
730730 return err
731731 }
0 commit comments