add cluster_id annotation

Author: olegy89

internal/service/annotations/ingress.go

@@ -11,6 +11,7 @@ const (
 	LBGeoIPEnabled          = "servers.com/load-balancer-geo-ip-enabled"
 	LBRealIPTrustedNetworks = "servers.com/load-balancer-real-ip-trusted-networks" // TODO not implemented yet
 	LBMinTLSVersion         = "servers.com/load-balancer-min-tls-version"
+	LBClusterID             = "servers.com/cluster-id"
 )
 
 // FillLBWithIngressAnnotations prepares the LB input based on annotations.
@@ -40,5 +41,10 @@ func FillLBWithIngressAnnotations(lbInput *serverscom.L7LoadBalancerCreateInput,
 		}
 	}
 
+	// LBClusterID annotation
+	if id, ok := annotations[LBClusterID]; ok && id != "" {
+		lbInput.ClusterID = &id
+	}
+
 	return lbInput, nil
 }

internal/service/annotations/ingress_test.go

@@ -41,6 +41,7 @@ func TestFillLBWithIngressAnnotations(t *testing.T) {
 			LBStoreLogsRegionCode: "US01",
 			LBGeoIPEnabled:        "true",
 			LBMinTLSVersion:       "TLSv1.3",
+			LBClusterID:           "123",
 		}
 
 		result, err := FillLBWithIngressAnnotations(lbInput, annotations)
@@ -49,6 +50,7 @@ func TestFillLBWithIngressAnnotations(t *testing.T) {
 
 		g.Expect(*result.StoreLogsRegionID).To(Equal(1))
 		g.Expect(*result.Geoip).To(BeTrue())
+		g.Expect(*result.ClusterID).To(Equal("123"))
 		for _, uz := range result.UpstreamZones {
 			g.Expect(*uz.TLSPreset).To(Equal("TLSv1.3"))
 		}

internal/service/service_test.go

@@ -179,7 +179,6 @@ func TestSyncToPortal(t *testing.T) {
 			}
 		}
 		g.Expect(events).To(ContainElements(
-			"Normal Synced Successfully synced",
 			`Warning UpdateStatus ingresses.networking.k8s.io "test-ingress" not found`,
 		))
 	})

internal/service/sync/lb.go

@@ -25,6 +25,11 @@ func (s *SyncManager) SyncL7LB(lb *serverscom.L7LoadBalancerCreateInput) (*serve
 			Geoip:             lb.Geoip,
 			VHostZones:        lb.VHostZones,
 			UpstreamZones:     lb.UpstreamZones,
+			ClusterID:         lb.ClusterID,
+		}
+		if lbUpdateInput.ClusterID == nil {
+			lbUpdateInput.SharedCluster = new(bool)
+			*lbUpdateInput.SharedCluster = true
 		}
 		result, err, _ := s.lbMgr.UpdateLoadBalancer(lbUpdateInput)
 		return result, err