From 3e76b6185bd98dc06ea2da3b66ba24c407a1bc4a Mon Sep 17 00:00:00 2001
From: kaiyou <dev@kaiyou.fr>
Date: Wed, 24 Jul 2024 22:48:36 +0200
Subject: [PATCH] Enable informer resync
---
k8s/clients.go | 16 ++++++----------
1 file changed, 6 insertions(+), 10 deletions(-)
diff --git a/k8s/clients.go b/k8s/clients.go
index bdf37bb..8b1390b 100644
--- a/k8s/clients.go
+++ b/k8s/clients.go
@@ -3,6 +3,7 @@ package k8s
import (
"context"
"net/url"
+ "time"
"go.acides.org/pekahi"
core "k8s.io/api/core/v1"
@@ -78,22 +79,17 @@ func newClientsForKC(kc *rest.Config) (*Clients, error) {
return nil, err
}
cachedClient := memory.NewMemCacheClient(baseClient)
- restMapper := restmapper.NewDeferredDiscoveryRESTMapper(cachedClient)
- broadcaster := events.NewEventBroadcasterAdapter(eventsClient)
- informers := informers.NewSharedInformerFactory(baseClient, 0)
- metadataInformers := metadatainformer.NewSharedInformerFactory(metadataClient, 0)
- dynInformers := dynamicinformer.NewFilteredDynamicSharedInformerFactory(dynClient, 0, core.NamespaceAll, nil)
return &Clients{
KubeConfig: kc,
Client: baseClient,
DynClient: dynClient,
EventClient: eventsClient,
MetadataClient: metadataClient,
- RESTMapper: restMapper,
- Broadcaster: broadcaster,
- Informer: informers,
- MetadataInformer: metadataInformers,
- DynInformer: dynInformers,
+ RESTMapper: restmapper.NewDeferredDiscoveryRESTMapper(cachedClient),
+ Broadcaster: events.NewEventBroadcasterAdapter(eventsClient),
+ Informer: informers.NewSharedInformerFactory(baseClient, 10*time.Minute),
+ MetadataInformer: metadatainformer.NewSharedInformerFactory(metadataClient, 10*time.Minute),
+ DynInformer: dynamicinformer.NewDynamicSharedInformerFactory(dynClient, 10*time.Minute),
}, nil
}
--
GitLab