Skip to content

Commit 9f18c0f

Browse files
committed
1 parent 817ef95 commit 9f18c0f

File tree

1 file changed

+6
-18
lines changed

1 file changed

+6
-18
lines changed

controllers/rabbitmqcluster_controller.go

Lines changed: 6 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -110,12 +110,8 @@ func (r *RabbitmqClusterReconciler) Reconcile(req ctrl.Request) (ctrl.Result, er
110110
return ctrl.Result{}, err
111111
}
112112

113-
requeueAfter, err := r.updateStatus(ctx, rabbitmqCluster)
114-
if err != nil {
115-
return ctrl.Result{}, err
116-
}
117-
if requeueAfter > 0 {
118-
return ctrl.Result{RequeueAfter: requeueAfter}, nil
113+
if requeueAfter, err := r.updateStatus(ctx, rabbitmqCluster); err != nil || requeueAfter > 0 {
114+
return ctrl.Result{RequeueAfter: requeueAfter}, err
119115
}
120116

121117
sts, err := r.statefulSet(ctx, rabbitmqCluster)
@@ -179,12 +175,8 @@ func (r *RabbitmqClusterReconciler) Reconcile(req ctrl.Request) (ctrl.Result, er
179175
}
180176
}
181177

182-
requeueAfter, err = r.restartStatefulSetIfNeeded(ctx, rabbitmqCluster)
183-
if err != nil {
184-
return ctrl.Result{}, err
185-
}
186-
if requeueAfter > 0 {
187-
return ctrl.Result{RequeueAfter: requeueAfter}, nil
178+
if requeueAfter, err := r.restartStatefulSetIfNeeded(ctx, rabbitmqCluster); err != nil || requeueAfter > 0 {
179+
return ctrl.Result{RequeueAfter: requeueAfter}, err
188180
}
189181

190182
// Set ReconcileSuccess to true here because all CRUD operations to Kube API related
@@ -202,12 +194,8 @@ func (r *RabbitmqClusterReconciler) Reconcile(req ctrl.Request) (ctrl.Result, er
202194

203195
// By this point the StatefulSet may have finished deploying. Run any
204196
// post-deploy steps if so, or requeue until the deployment is finished.
205-
requeueAfter, err = r.runRabbitmqCLICommandsIfAnnotated(ctx, rabbitmqCluster)
206-
if err != nil {
207-
return ctrl.Result{}, err
208-
}
209-
if requeueAfter > 0 {
210-
return ctrl.Result{RequeueAfter: requeueAfter}, nil
197+
if requeueAfter, err := r.runRabbitmqCLICommandsIfAnnotated(ctx, rabbitmqCluster); err != nil || requeueAfter > 0 {
198+
return ctrl.Result{RequeueAfter: requeueAfter}, err
211199
}
212200

213201
logger.Info("Finished reconciling RabbitmqCluster",

0 commit comments

Comments
 (0)