some fix

* ensure requeue if port pool not found
* ignore lb not found error when cleaup clb binding

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

Author: imroc

internal/controller/clbbinding.go

@@ -64,23 +64,6 @@ func (r *CLBBindingReconciler[T]) sync(ctx context.Context, bd T) (result ctrl.R
 	// 确保所有端口都已分配且绑定 obj
 	if err := r.ensureCLBBinding(ctx, bd); err != nil {
 		errCause := errors.Cause(err)
-		if e, ok := errCause.(*portpool.ErrPoolNotFound); ok { // 分配端口时发现端口池不在分配器缓存中
-			// 看是否有这个端口池对象
-			poolName := e.Pool
-			pp := &networkingv1alpha1.CLBPortPool{}
-			if err := r.Client.Get(ctx, client.ObjectKey{Name: poolName}, pp); err != nil {
-				if apierrors.IsNotFound(err) { // 端口池确实不存在，更新状态和 event
-					r.Recorder.Event(bd.GetObject(), corev1.EventTypeWarning, "PoolNotFound", "port pool not found, please check the port pool name")
-					if err := r.ensureState(ctx, bd, networkingv1alpha1.CLBBindingStatePortPoolNotFound); err != nil {
-						return result, errors.WithStack(err)
-					}
-					return result, nil
-				}
-				return result, errors.WithStack(err)
-			} else { // 端口池存在，但还没更新到分配器缓存，忽略，等待端口池就绪后会自动触发重新对账
-				return result, nil
-			}
-		}
 		// 1. 扩容了 lb、或者正在扩容，忽略，因为会自动触发对账。
 		// 2. 端口不足无法分配、端口池不存在，忽略，因为如果端口池不改正或扩容 lb，无法重试成功。
 		// 3. lb 被删除或监听器被删除，自动移除了 status 中的记录，需重新入队对账。
@@ -98,6 +81,24 @@ func (r *CLBBindingReconciler[T]) sync(ctx context.Context, bd T) (result ctrl.R
 			}
 			return result, nil
 		}
+		// 分配端口时发现端口池不在分配器缓存中
+		if e, ok := errCause.(*portpool.ErrPoolNotFound); ok {
+			// 看是否有这个端口池对象
+			poolName := e.Pool
+			pp := &networkingv1alpha1.CLBPortPool{}
+			if err := r.Client.Get(ctx, client.ObjectKey{Name: poolName}, pp); err != nil {
+				if apierrors.IsNotFound(err) { // 端口池确实不存在，更新状态和 event
+					r.Recorder.Eventf(bd.GetObject(), corev1.EventTypeWarning, "PoolNotFound", "port pool %q not found, please check the port pool name", poolName)
+					if err := r.ensureState(ctx, bd, networkingv1alpha1.CLBBindingStatePortPoolNotFound); err != nil {
+						return result, errors.WithStack(err)
+					}
+				}
+				return result, errors.WithStack(err)
+			} else { // 端口池存在，但还没更新到分配器缓存，忽略，等待端口池就绪后会自动触发重新对账
+				result.RequeueAfter = 20 * time.Microsecond
+				return result, nil
+			}
+		}
 		// 如果是被云 API 限流（默认每秒 20 qps 限制），1s 后重新入队
 		if clb.IsRequestLimitExceededError(errCause) {
 			result.RequeueAfter = time.Second
@@ -739,6 +740,9 @@ func (r *CLBBindingReconciler[T]) cleanup(ctx context.Context, bd T) (result ctr
 func (r *CLBBindingReconciler[T]) cleanupPortBinding(ctx context.Context, binding *networkingv1alpha1.PortBindingStatus) error {
 	lis, err := clb.GetListenerByIdOrPort(ctx, binding.Region, binding.LoadbalancerId, binding.ListenerId, int64(binding.LoadbalancerPort), binding.Protocol)
 	if err != nil {
+		if clb.IsLoadBalancerNotExistsError(err) { // 忽略 lbid 不存在的错误，就当清理成功
+			return nil
+		}
 		return errors.WithStack(err)
 	}
 	releasePort := func() {

pkg/clb/batch-target.go

@@ -113,15 +113,8 @@ func startDescribeTargetsProccessor(concurrent int) {
 			targetsMap[*backend.ListenerId] = targets
 		}
 		for _, task := range tasks {
-			targets := targetsMap[task.ListenerId]
-			if targets == nil {
-				task.Result <- &DescribeTargetsResult{
-					Err: fmt.Errorf("no targets result for %s/%s", task.LbId, task.ListenerId),
-				}
-			} else {
-				task.Result <- &DescribeTargetsResult{
-					Targets: targetsMap[task.ListenerId],
-				}
+			task.Result <- &DescribeTargetsResult{
+				Targets: targetsMap[task.ListenerId],
 			}
 		}
 	})