From f0bc661579b58702fc8fd60b35ca5432764ad470 Mon Sep 17 00:00:00 2001 From: jwcesign Date: Thu, 14 Dec 2023 21:52:23 +0800 Subject: [PATCH] fix: Update RB once new clusters are added to trigger the propagation of service to these new clusters Signed-off-by: jwcesign --- pkg/controllers/multiclusterservice/mcs_controller.go | 9 --------- 1 file changed, 9 deletions(-) diff --git a/pkg/controllers/multiclusterservice/mcs_controller.go b/pkg/controllers/multiclusterservice/mcs_controller.go index 196fd8d91..dcac5a29f 100644 --- a/pkg/controllers/multiclusterservice/mcs_controller.go +++ b/pkg/controllers/multiclusterservice/mcs_controller.go @@ -418,16 +418,7 @@ func (c *MCSController) propagateService(ctx context.Context, mcs *networkingv1a func (c *MCSController) buildResourceBinding(svc *corev1.Service, mcs *networkingv1alpha1.MultiClusterService, providerClusters, consumerClusters sets.Set[string]) (*workv1alpha2.ResourceBinding, error) { - allClusters, err := util.GetClusterSet(c.Client) - if err != nil { - klog.Errorf("Failed to get all clusters:%v", err) - return nil, err - } - propagateClusters := providerClusters.Clone().Insert(consumerClusters.Clone().UnsortedList()...) - if propagateClusters.Equal(allClusters) { - propagateClusters = sets.Set[string]{} - } placement := &policyv1alpha1.Placement{ ClusterAffinity: &policyv1alpha1.ClusterAffinity{ ClusterNames: propagateClusters.UnsortedList(),