From a8e8cfb72dbd3d4d7c260305ac43f25a4843b1ae 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 33ef7de1..c543b599 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)