Feat: add 5min resync in logconfig and kube informer

loggie-io · Mar 15, 2024 · 750de04 · 750de04
1 parent ab29042
commit 750de04
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/pkg/discovery/kubernetes/kubernetes.go b/pkg/discovery/kubernetes/kubernetes.go
@@ -30,6 +30,7 @@ import (
 	"k8s.io/client-go/tools/cache"
 	"k8s.io/client-go/tools/clientcmd"
 	"strings"
+	"time"
 
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	kubeinformers "k8s.io/client-go/informers"
@@ -98,9 +99,9 @@ func (d *Discovery) Start(stopCh <-chan struct{}) {
 		log.Panic("Error building logConf clientset: %s", err.Error())
 	}
 
-	logConfInformerFactory := logconfigInformer.NewSharedInformerFactory(logConfigClient, 0)
+	logConfInformerFactory := logconfigInformer.NewSharedInformerFactory(logConfigClient, 5*time.Minute)
 
-	kubeInformerFactory := kubeinformers.NewSharedInformerFactoryWithOptions(kubeClient, 0, kubeinformers.WithTweakListOptions(func(lo *metav1.ListOptions) {
+	kubeInformerFactory := kubeinformers.NewSharedInformerFactoryWithOptions(kubeClient, 5*time.Minute, kubeinformers.WithTweakListOptions(func(lo *metav1.ListOptions) {
 		lo.FieldSelector = fields.OneTermEqualSelector("spec.nodeName", d.config.NodeName).String()
 	}))