Skip to content

Commit 41b912b

Browse files
committed
Optimize replicaset informers
1 parent b6ab5fd commit 41b912b

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

pkg/pipeline/transform/kubernetes/informers/informers.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,7 @@ import (
3232
"github.com/sirupsen/logrus"
3333
v1 "k8s.io/api/core/v1"
3434
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
35+
"k8s.io/apimachinery/pkg/fields"
3536
"k8s.io/apimachinery/pkg/runtime/schema"
3637
"k8s.io/client-go/dynamic"
3738
inf "k8s.io/client-go/informers"
@@ -412,7 +413,9 @@ func (k *Informers) InitFromConfig(kubeconfig string, infConfig Config, opMetric
412413

413414
func (k *Informers) initInformers(client kubernetes.Interface, metaClient metadata.Interface, dynClient *dynamic.DynamicClient, cfg Config) error {
414415
informerFactory := inf.NewSharedInformerFactory(client, syncTime)
415-
metadataInformerFactory := metadatainformer.NewSharedInformerFactory(metaClient, syncTime)
416+
metadataInformerFactory := metadatainformer.NewFilteredSharedInformerFactory(metaClient, syncTime, metav1.NamespaceAll, func(options *metav1.ListOptions) {
417+
options.FieldSelector = fields.OneTermNotEqualSelector("status.replicas", "0").String()
418+
})
416419
err := k.initNodeInformer(informerFactory, cfg)
417420
if err != nil {
418421
return err

0 commit comments

Comments
 (0)