set requeue time for etcd proxy

Signed-off-by: nasusoba <[email protected]>
k3s-io · Jun 14, 2024 · 891e1b5 · 891e1b5
1 parent 888216c
commit 891e1b5
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 2 deletions.
diff --git a/controlplane/controllers/const.go b/controlplane/controllers/const.go
@@ -31,5 +31,9 @@ const (
 	// dependent certificates have been created.
 	dependentCertRequeueAfter = 30 * time.Second
 
+	// etcdRemovalRequeueAfter is how long to wait before checking again to see if
+	// etcd member is successfully removed.
+	etcdRemovalRequeueAfter = 30 * time.Second
+
 	k3sHookName = "k3s"
 )
diff --git a/controlplane/controllers/kthreescontrolplane_controller.go b/controlplane/controllers/kthreescontrolplane_controller.go
@@ -97,7 +97,7 @@ func (r *KThreesControlPlaneReconciler) Reconcile(ctx context.Context, req ctrl.
 	}
 	if cluster == nil {
 		logger.Info("Cluster Controller has not yet set OwnerRef")
-		return ctrl.Result{Requeue: true}, nil
+		return ctrl.Result{}, nil
 	}
 	logger = logger.WithValues("cluster", cluster.Name)
 

diff --git a/controlplane/controllers/machine_controller.go b/controlplane/controllers/machine_controller.go
@@ -130,7 +130,7 @@ func (r *MachineReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ct
 			}
 			if !etcdRemoved {
 				logger.Info("wait k3s embedded etcd controller to remove etcd")
-				return ctrl.Result{Requeue: true}, err
+				return ctrl.Result{RequeueAfter: etcdRemovalRequeueAfter}, nil
 			}
 
 			nodeName := ""