accelerate retry

Signed-off-by: roc <[email protected]>

Author: imroc

internal/controller/clbbinding.go

@@ -71,11 +71,11 @@ func (r *CLBBindingReconciler[T]) sync(ctx context.Context, bd T) (result ctrl.R
 		case portpool.ErrNewLBCreated, portpool.ErrNewLBCreating:
 			return result, nil
 		case portpool.ErrNoLbReady:
-			result.Requeue = true
+			result.RequeueAfter = time.Second
 			log.FromContext(ctx).Info("requeue due to lb not ready yet")
 			return result, nil
 		case ErrNeedRetry:
-			result.Requeue = true
+			result.RequeueAfter = 20 * time.Millisecond
 			log.FromContext(ctx).Info("requeue due to listener need to be re-allocated")
 			return result, nil
 		case portpool.ErrNoPortAvailable:
@@ -98,7 +98,7 @@ func (r *CLBBindingReconciler[T]) sync(ctx context.Context, bd T) (result ctrl.R
 				}
 				return result, errors.WithStack(err)
 			} else { // 端口池存在，但还没更新到分配器缓存，重新入队
-				result.Requeue = true
+				result.RequeueAfter = 20 * time.Millisecond
 				log.FromContext(ctx).Info("requeue due to port pool not ready yet")
 				return result, nil
 			}
@@ -107,7 +107,7 @@ func (r *CLBBindingReconciler[T]) sync(ctx context.Context, bd T) (result ctrl.R
 		if clb.IsRequestLimitExceededError(errCause) {
 			result.RequeueAfter = time.Second
 			log.FromContext(ctx).Info("requeue due to clb api request limit exceeded when reconciling")
-			return result, errors.WithStack(err)
+			return result, nil
 		}
 
 		if !apierrors.IsConflict(errCause) { // 其它非资源冲突的错误，将错误记录到 event 和状态中方便排障
@@ -684,7 +684,7 @@ func (r *CLBBindingReconciler[T]) cleanup(ctx context.Context, bd T) (result ctr
 				continue
 			case clb.ErrOtherListenerNotFound: // 因同一批次删除的其它监听器不存在导致删除失败，需重试
 				log.Error(err, "requeue due to delete listener failed cuz other listener not found")
-				result.Requeue = true
+				result.RequeueAfter = 20 * time.Millisecond
 				return result, nil
 			}
 			if clb.IsLoadBalancerNotExistsError(e) { // lb 不存在，忽略

internal/controller/util.go

@@ -2,6 +2,7 @@ package controller
 
 import (
 	"context"
+	"time"
 
 	"github.com/imroc/tke-extend-network-controller/internal/constant"
 	"github.com/imroc/tke-extend-network-controller/pkg/kube"
@@ -31,7 +32,7 @@ func Reconcile[T client.Object](ctx context.Context, req ctrl.Request, apiClient
 		if apierrors.IsConflict(err) {
 			if !result.Requeue && result.RequeueAfter == 0 {
 				log.FromContext(ctx).Info("requeue due to k8s api conflict")
-				result.Requeue = true
+				result.RequeueAfter = 20 * time.Millisecond
 			}
 			return result, nil
 		}