diff --git a/pkg/agent/memberlist/cluster.go b/pkg/agent/memberlist/cluster.go index bbacc5a2889..ee4d2c8de80 100644 --- a/pkg/agent/memberlist/cluster.go +++ b/pkg/agent/memberlist/cluster.go @@ -277,23 +277,6 @@ func (c *Cluster) newClusterMember(node *corev1.Node) (string, error) { return nodeAddr.String(), nil } -func (c *Cluster) allClusterMembers() (clusterNodes []string, err error) { - nodes, err := c.nodeLister.List(labels.Everything()) - if err != nil { - return nil, fmt.Errorf("listing Nodes error: %v", err) - } - - for _, node := range nodes { - member, err := c.newClusterMember(node) - if err != nil { - klog.ErrorS(err, "Get Node failed") - continue - } - clusterNodes = append(clusterNodes, member) - } - return -} - func (c *Cluster) filterEIPsFromNodeLabels(node *corev1.Node) sets.String { pools := sets.NewString() eips, err := c.externalIPPoolLister.List(labels.Everything()) @@ -327,16 +310,6 @@ func (c *Cluster) Run(stopCh <-chan struct{}) { return } - members, err := c.allClusterMembers() - if err != nil { - klog.ErrorS(err, "List cluster members failed") - } else if members != nil { - _, err := c.mList.Join(members) - if err != nil { - klog.ErrorS(err, "Join cluster failed") - } - } - for i := 0; i < defaultWorkers; i++ { go wait.Until(c.worker, time.Second, stopCh) } diff --git a/pkg/agent/memberlist/cluster_test.go b/pkg/agent/memberlist/cluster_test.go index 87a7929194a..d337657e464 100644 --- a/pkg/agent/memberlist/cluster_test.go +++ b/pkg/agent/memberlist/cluster_test.go @@ -157,9 +157,6 @@ func TestCluster_Run(t *testing.T) { res, err := fakeCluster.cluster.ShouldSelectIP(tCase.egress.Spec.EgressIP, eip.Name) return err == nil && res == tCase.expectEgressSelectResult, nil }), "select Node result for Egress does not match") - allMembers, err := fakeCluster.cluster.allClusterMembers() - assert.NoError(t, err) - assert.Len(t, allMembers, 1, "expected Node member num is 1") assert.Equal(t, 1, fakeCluster.cluster.mList.NumMembers(), "expected alive Node num is 1") }) }