fix: updateLoadBalancer only when all nodes are initialized

Author: Tomy2e

scaleway/loadbalancers.go

@@ -29,6 +29,7 @@ import (
 
 	"golang.org/x/exp/slices"
 	v1 "k8s.io/api/core/v1"
+	"k8s.io/cloud-provider/api"
 	"k8s.io/klog/v2"
 
 	scwipam "github.com/scaleway/scaleway-sdk-go/api/ipam/v1"
@@ -566,6 +567,10 @@ func (l *loadbalancers) updateLoadBalancer(ctx context.Context, loadbalancer *sc
 		return fmt.Errorf("invalid value for annotation %s: expected boolean", serviceAnnotationLoadBalancerExternallyManaged)
 	}
 
+	if err := nodesInitialized(nodes); err != nil {
+		return err
+	}
+
 	nodes = filterNodes(service, nodes)
 	if l.pnID != "" {
 		respPN, err := l.api.ListLBPrivateNetworks(&scwlb.ZonedAPIListLBPrivateNetworksRequest{
@@ -1673,3 +1678,16 @@ func ptrBoolToString(b *bool) string {
 	}
 	return fmt.Sprintf("%t", *b)
 }
+
+// nodesInitialized verifies that all nodes are initialized before using them as LoadBalancer targets.
+func nodesInitialized(nodes []*v1.Node) error {
+	for _, node := range nodes {
+		if slices.ContainsFunc(node.Spec.Taints, func(taint v1.Taint) bool {
+			return taint.Key == api.TaintExternalCloudProvider
+		}) {
+			return fmt.Errorf("node %s is not yet initialized", node.Name)
+		}
+	}
+
+	return nil
+}

scaleway/loadbalancers_test.go

@@ -27,6 +27,7 @@ import (
 	"github.com/scaleway/scaleway-sdk-go/scw"
 	v1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/cloud-provider/api"
 )
 
 func TestGetValueForPort(t *testing.T) {
@@ -1255,3 +1256,57 @@ func deepCloneBackend(original *scwlb.Backend) *scwlb.Backend {
 
 	return clone
 }
+
+func Test_nodesInitialized(t *testing.T) {
+	type args struct {
+		nodes []*v1.Node
+	}
+	tests := []struct {
+		name    string
+		args    args
+		wantErr bool
+	}{
+		{
+			name: "node initialized",
+			args: args{
+				nodes: []*v1.Node{
+					{
+						ObjectMeta: metav1.ObjectMeta{
+							Name: "test",
+						},
+					},
+				},
+			},
+			wantErr: false,
+		},
+		{
+			name: "node not initialized",
+			args: args{
+				nodes: []*v1.Node{
+					{
+						ObjectMeta: metav1.ObjectMeta{
+							Name: "test",
+						},
+						Spec: v1.NodeSpec{
+							Taints: []v1.Taint{
+								{
+									Key:    api.TaintExternalCloudProvider,
+									Value:  "true",
+									Effect: v1.TaintEffectNoSchedule,
+								},
+							},
+						},
+					},
+				},
+			},
+			wantErr: true,
+		},
+	}
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			if err := nodesInitialized(tt.args.nodes); (err != nil) != tt.wantErr {
+				t.Errorf("nodesInitialized() error = %v, wantErr %v", err, tt.wantErr)
+			}
+		})
+	}
+}