From 79ba9855beb89b4553bbfb977980e32f08f7d8e9 Mon Sep 17 00:00:00 2001 From: up9-github Date: Sun, 25 Apr 2021 13:42:45 +0300 Subject: [PATCH] Update mizu.go --- cli/mizu/mizu.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/cli/mizu/mizu.go b/cli/mizu/mizu.go index 45daabe7c..a50ce3cd1 100644 --- a/cli/mizu/mizu.go +++ b/cli/mizu/mizu.go @@ -36,7 +36,7 @@ func Run(podRegex *regexp.Regexp) { } func watchPodsForTapping(ctx context.Context, kubernetesProvider *kubernetes.Provider, cancel context.CancelFunc, podRegex *regexp.Regexp) { - added, _, removed, errorChan := kubernetes.FilteredWatch(ctx, kubernetesProvider.GetPodWatcher(ctx), podRegex) + added, modified, removed, errorChan := kubernetes.FilteredWatch(ctx, kubernetesProvider.GetPodWatcher(ctx), podRegex) for { select { case newTarget := <- added: @@ -45,6 +45,9 @@ func watchPodsForTapping(ctx context.Context, kubernetesProvider *kubernetes.Pro case removedTarget := <- removed: fmt.Printf("-%s\n", removedTarget.Name) + case <- modified: + continue + case <- errorChan: cancel()