Merge pull request #114 from butonic/registry/kubernetes/watcher-fix

only close channel once
micro · Jun 5, 2023 · a179a6b · a179a6b
2 parents d4d5318 + 51f3d8c
commit a179a6b
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/v4/registry/kubernetes/watcher.go b/v4/registry/kubernetes/watcher.go
@@ -24,6 +24,7 @@ type k8sWatcher struct {
 
 	sync.RWMutex
 	pods map[string]*client.Pod
+	sync.Once
 }
 
 // build a cache of pods when the watcher starts.
@@ -164,7 +165,9 @@ func (k *k8sWatcher) Stop() {
 	case <-k.next:
 		return
 	default:
-		close(k.next)
+		k.Do(func() {
+			close(k.next)
+		})
 	}
 }