From 6d7e55c4667c08c600db3c615ec3bad2b47d102f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E9=9C=96?= Date: Thu, 23 Mar 2023 14:22:20 +0800 Subject: [PATCH] fix: websocket event listener (#2745) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: 李霖 --- pkg/executor/executortype/poolmgr/gpm.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/executor/executortype/poolmgr/gpm.go b/pkg/executor/executortype/poolmgr/gpm.go index 33ef7de17..c543b5997 100644 --- a/pkg/executor/executortype/poolmgr/gpm.go +++ b/pkg/executor/executortype/poolmgr/gpm.go @@ -711,7 +711,7 @@ func (gpm *GenericPoolManager) NoActiveConnectionEventChecker(ctx context.Contex defer close(stopper) var wg wait.Group - for _, informer := range utils.GetInformerEventChecker(ctx, kubeClient, "WsConnectionStarted") { + for _, informer := range utils.GetInformerEventChecker(ctx, kubeClient, "NoActiveConnections") { informer.AddEventHandler(k8sCache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { mObj := obj.(metav1.Object)