set clbbinding state to WaitBackend if pod is not scheduled yet

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

Author: imroc

internal/clbbinding/clbpodbinding.go

@@ -57,10 +57,12 @@ func (b podBackend) GetObject() client.Object {
 	return b.Pod
 }
 
+var ErrNodeNameIsEmpty = errors.New("node name is empty")
+
 func (b podBackend) GetNode(ctx context.Context) (*corev1.Node, error) {
 	nodeName := b.Pod.Spec.NodeName
 	if nodeName == "" {
-		return nil, errors.New("node name is empty")
+		return nil, ErrNodeNameIsEmpty
 	}
 	node := &corev1.Node{}
 	err := b.Client.Get(ctx, client.ObjectKey{Name: nodeName}, node)

internal/controller/clbbinding.go

@@ -216,6 +216,13 @@ func (r *CLBBindingReconciler[T]) ensureBackendBindings(ctx context.Context, bd
 	}
 	node, err := backend.GetNode(ctx)
 	if err != nil {
+		if err == clbbinding.ErrNodeNameIsEmpty { // pod 还未调度
+			r.Recorder.Event(bd.GetObject(), corev1.EventTypeNormal, "WaitBackend", "wait pod to be scheduled")
+			if err = r.ensureState(ctx, bd, networkingv1alpha1.CLBBindingStateWaitBackend); err != nil {
+				return errors.WithStack(err)
+			}
+			return nil
+		}
 		return errors.WithStack(err)
 	}
 	if !util.IsNodeTypeSupported(node) {