github/kubeshark
1
0
Fork 0
mirror of https://github.com/kubeshark/kubeshark.git synced 2025-07-06 12:59:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update mizu.go

Browse Source
This commit is contained in:
up9-github 2021-04-25 13:42:45 +03:00
parent ff6922d528
commit 79ba9855be
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
cli/mizu/mizu.go
View File

@ -36,7 +36,7 @@ func Run(podRegex *regexp.Regexp) {
} }
func watchPodsForTapping(ctx context.Context, kubernetesProvider *kubernetes.Provider, cancel context.CancelFunc, 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 { for {
select { select {
case newTarget := <- added: case newTarget := <- added:
@ -45,6 +45,9 @@ func watchPodsForTapping(ctx context.Context, kubernetesProvider *kubernetes.Pro
case removedTarget := <- removed: case removedTarget := <- removed:
fmt.Printf("-%s\n", removedTarget.Name) fmt.Printf("-%s\n", removedTarget.Name)
case <- modified:
continue
case <- errorChan: case <- errorChan:
cancel() cancel()