diff --git a/cmd/glbc/main.go b/cmd/glbc/main.go index 3d51658844..4ad58b4d95 100644 --- a/cmd/glbc/main.go +++ b/cmd/glbc/main.go @@ -263,7 +263,9 @@ func main() { } var nodeTopologyFactory informernodetopology.SharedInformerFactory if nodeTopologyClient != nil { - nodeTopologyFactory = informernodetopology.NewSharedInformerFactory(nodeTopologyClient, flags.F.ResyncPeriod) + nodeTopologyFactory = informernodetopology.NewSharedInformerFactoryWithOptions(nodeTopologyClient, flags.F.ResyncPeriod, informernodetopology.WithTweakListOptions(func(listOptions *metav1.ListOptions) { + listOptions.FieldSelector = fmt.Sprintf("metadata.name=%s", flags.F.NodeTopologyCRName) + })) } if flags.F.LeaderElection.LeaderElect { err := multiprojectstart.StartWithLeaderElection( diff --git a/pkg/multiproject/neg/neg.go b/pkg/multiproject/neg/neg.go index 58a5a54190..daa6501e24 100644 --- a/pkg/multiproject/neg/neg.go +++ b/pkg/multiproject/neg/neg.go @@ -95,6 +95,7 @@ func StartNEGController( informers.providerConfigFilteredSvcNegInformer, informers.providerConfigFilteredNetworkInformer, informers.providerConfigFilteredGkeNetworkParamsInformer, + informers.providerConfigFilteredNodeTopologyInformer, hasSynced, cloud, zoneGetter, @@ -253,6 +254,7 @@ func createNEGController( svcNegInformer cache.SharedIndexInformer, networkInformer cache.SharedIndexInformer, gkeNetworkParamsInformer cache.SharedIndexInformer, + nodeTopologyInformer cache.SharedIndexInformer, hasSynced func() bool, cloud *gce.Cloud, zoneGetter *zonegetter.ZoneGetter, @@ -271,7 +273,6 @@ func createNEGController( } noDefaultBackendServicePort := utils.ServicePort{} - var noNodeTopologyInformer cache.SharedIndexInformer negController, err := neg.NewController( kubeClient, @@ -286,7 +287,7 @@ func createNEGController( svcNegInformer, networkInformer, gkeNetworkParamsInformer, - noNodeTopologyInformer, + nodeTopologyInformer, hasSynced, l4Namer, noDefaultBackendServicePort,