From 2ed67fcdc67984daca7a4d5c83af6313214b5d07 Mon Sep 17 00:00:00 2001 From: youys <1272586223@qq.com> Date: Wed, 22 Oct 2025 15:46:01 +0800 Subject: [PATCH] =?UTF-8?q?fix(pod.go):=20=E4=B8=8D=E5=AE=9E=E6=97=B6?= =?UTF-8?q?=E8=8E=B7=E5=8F=96pod=E4=BA=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- server/internal/data/pod.go | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) diff --git a/server/internal/data/pod.go b/server/internal/data/pod.go index fa2eaf4..1d19db8 100644 --- a/server/internal/data/pod.go +++ b/server/internal/data/pod.go @@ -15,7 +15,6 @@ import ( k8stypes "k8s.io/apimachinery/pkg/types" "k8s.io/client-go/informers" listerscorev1 "k8s.io/client-go/listers/core/v1" - "k8s.io/client-go/tools/cache" ) type podRepo struct { @@ -41,12 +40,12 @@ func NewPodRepo(data *Data, logger log.Logger) biz.PodRepo { func (r *podRepo) init() { informerFactory := informers.NewSharedInformerFactoryWithOptions(r.data.k8sCl, time.Hour*1) r.podLister = informerFactory.Core().V1().Pods().Lister() - informer := informerFactory.Core().V1().Pods().Informer() - informer.AddEventHandler(cache.ResourceEventHandlerFuncs{ - AddFunc: r.onAddPod, - UpdateFunc: r.onUpdatePod, - DeleteFunc: r.onDeletedPod, - }) + //informer := informerFactory.Core().V1().Pods().Informer() + //informer.AddEventHandler(cache.ResourceEventHandlerFuncs{ + // AddFunc: r.onAddPod, + // UpdateFunc: r.onUpdatePod, + // DeleteFunc: r.onDeletedPod, + //}) stopCh := make(chan struct{}) informerFactory.Start(stopCh) informerFactory.WaitForCacheSync(stopCh)