github/kubeshark
1
0
Fork 0
mirror of https://github.com/kubeshark/kubeshark.git synced 2025-09-21 10:06:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update tapRunner.go

Browse Source
This commit is contained in:
RamiBerm
2021-07-20 09:58:08 +03:00
parent 9d9f64098e
commit 1d24188a02
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
cli/cmd/tapRunner.go
View File

@@ -230,6 +230,7 @@ func portForwardApiPod(ctx context.Context, kubernetesProvider *kubernetes.Provi
podExactRegex := regexp.MustCompile(fmt.Sprintf("^%s$", mizu.AggregatorPodName)) podExactRegex := regexp.MustCompile(fmt.Sprintf("^%s$", mizu.AggregatorPodName))
added, modified, removed, errorChan := kubernetes.FilteredWatch(ctx, kubernetesProvider.GetPodWatcher(ctx, mizu.ResourcesNamespace), podExactRegex) added, modified, removed, errorChan := kubernetes.FilteredWatch(ctx, kubernetesProvider.GetPodWatcher(ctx, mizu.ResourcesNamespace), podExactRegex)
isPodReady := false isPodReady := false
timeAfter := time.After(25 * time.Second)
for { for {
select { select {
case <-added: case <-added:
@@ -269,7 +270,7 @@ func portForwardApiPod(ctx context.Context, kubernetesProvider *kubernetes.Provi
} }
} }
case <-time.After(25 * time.Second): case <- timeAfter:
if !isPodReady { if !isPodReady {
fmt.Printf("error: %s pod was not ready in time", mizu.AggregatorPodName) fmt.Printf("error: %s pod was not ready in time", mizu.AggregatorPodName)
cancel() cancel()