github/kubeshark
1
0
Fork 0
mirror of https://github.com/kubeshark/kubeshark.git synced 2025-07-17 09:51:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

.

Browse Source
This commit is contained in:
Igor Gov 2021-07-12 12:09:59 +03:00
parent 77e01da6e8
commit 60431b2836
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cli/cmd/tapRunner.go
View File

@ -252,12 +252,12 @@ func portForwardApiPod(ctx context.Context, kubernetesProvider *kubernetes.Provi
time.Sleep(time.Second * 5) // Waiting to be sure the proxy is ready time.Sleep(time.Second * 5) // Waiting to be sure the proxy is ready
if tappingOptions.Analyze { if tappingOptions.Analyze {
url_path := fmt.Sprintf("http://localhost:%d/api/uploadEntries?dest=%s", tappingOptions.GuiPort, url.QueryEscape(tappingOptions.AnalyzeDestination)) url_path := fmt.Sprintf("http://%s/api/uploadEntries?dest=%s", mizuProxiedUrl, tappingOptions.AnalyzeDestination)
u, err := url.ParseRequestURI(url_path) u, err := url.ParseRequestURI(url_path)
if err != nil { if err != nil {
log.Fatal(fmt.Sprintf("Failed parsing the URL %v\n", err)) log.Fatal(fmt.Sprintf("Failed parsing the URL %v\n", err))
} }
if _, err := http.Get(u.String()); err != nil { if response, err := http.Get(u.String()); err != nil && response.StatusCode != 200 {
fmt.Printf("error sending upload entries req %v\n", err) fmt.Printf("error sending upload entries req %v\n", err)
} else { } else {
fmt.Printf(mizu.Purple, "Traffic is uploading to UP9 for further analsys") fmt.Printf(mizu.Purple, "Traffic is uploading to UP9 for further analsys")