diff --git a/cli/cmd/tap.go b/cli/cmd/tap.go index bd649baa9..c23afd56f 100644 --- a/cli/cmd/tap.go +++ b/cli/cmd/tap.go @@ -16,7 +16,7 @@ type MizuTapOptions struct { Namespace string AllNamespaces bool Analyze bool - AnalyzeDestination string + AnalyzeDestination string KubeConfigPath string MizuImage string MizuPodPort uint16 @@ -63,7 +63,7 @@ func init() { tapCmd.Flags().Uint16VarP(&mizuTapOptions.GuiPort, "gui-port", "p", 8899, "Provide a custom port for the web interface webserver") tapCmd.Flags().StringVarP(&mizuTapOptions.Namespace, "namespace", "n", "", "Namespace selector") - tapCmd.Flags().BoolVar(&mizuTapOptions.Analyze, "analyze", false, "Analyze traffic") + tapCmd.Flags().BoolVar(&mizuTapOptions.Analyze, "analyze", false, "Uploads traffic to UP9 cloud for further analysis") tapCmd.Flags().StringVar(&mizuTapOptions.AnalyzeDestination, "dest", "up9.app", "Destination environment") tapCmd.Flags().BoolVarP(&mizuTapOptions.AllNamespaces, "all-namespaces", "A", false, "Tap all namespaces") tapCmd.Flags().StringVarP(&mizuTapOptions.KubeConfigPath, "kube-config", "k", "", "Path to kube-config file") diff --git a/cli/cmd/tapRunner.go b/cli/cmd/tapRunner.go index b4d6cca87..7019c4715 100644 --- a/cli/cmd/tapRunner.go +++ b/cli/cmd/tapRunner.go @@ -73,7 +73,7 @@ func RunMizuTap(podRegexQuery *regexp.Regexp, tappingOptions *MizuTapOptions) { return } - go portForwardApiPod(ctx, kubernetesProvider, cancel, tappingOptions, ) // TODO convert this to job for built in pod ttl or have the running app handle this + go portForwardApiPod(ctx, kubernetesProvider, cancel, tappingOptions) // TODO convert this to job for built in pod ttl or have the running app handle this go watchPodsForTapping(ctx, kubernetesProvider, cancel, podRegexQuery, tappingOptions) go syncApiStatus(ctx, cancel, tappingOptions) @@ -86,7 +86,6 @@ type GuestToken struct { Model string `json:"model"` } - func getGuestToken(url string, target *GuestToken) error { resp, err := http.Get(url) if err != nil { @@ -104,8 +103,6 @@ func CreateAnonymousToken(envPrefix string) (*GuestToken, error) { fmt.Println(err) return nil, err } - - fmt.Println("Token:", token.Token, "model:", token.Model) return token, nil } @@ -283,6 +280,7 @@ func portForwardApiPod(ctx context.Context, kubernetesProvider *kubernetes.Provi if _, err := http.Get(fmt.Sprintf("http://localhost:%d/api/uploadEntries?token=%s&model=%s&dest=%s", tappingOptions.GuiPort, token.Token, token.Model, tappingOptions.AnalyzeDestination)); err != nil { fmt.Println(err) } else { + fmt.Println("Staring to upload and analyze the data, it may take a few minutes") fmt.Println("https://" + tappingOptions.AnalyzeDestination + "/share/" + token.Token) } }