From cd9433ea3af6d39a087bab9a24ced52fbe8e45f8 Mon Sep 17 00:00:00 2001 From: "M. Mert Yildiran" Date: Sat, 26 Nov 2022 21:47:47 +0300 Subject: [PATCH] :hammer: Fix the broken call to `*connect.Connector` --- cmd/tapRunner.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/cmd/tapRunner.go b/cmd/tapRunner.go index d2815c22c..c0753b142 100644 --- a/cmd/tapRunner.go +++ b/cmd/tapRunner.go @@ -43,7 +43,7 @@ var proxyDone bool func RunKubesharkTap() { state.startTime = time.Now() - connector = connect.NewProvider(kubernetes.GetLocalhostOnPort(config.Config.Hub.PortForward.SrcPort), connect.DefaultRetries, connect.DefaultTimeout) + connector = connect.NewConnector(kubernetes.GetLocalhostOnPort(config.Config.Hub.PortForward.SrcPort), connect.DefaultRetries, connect.DefaultTimeout) kubernetesProvider, err := getKubernetesProviderForCli() if err != nil { @@ -187,7 +187,7 @@ func startTapperSyncer(ctx context.Context, cancel context.CancelFunc, provider log.Print("kubesharkTapperSyncer pod changes channel closed, ending listener loop") return } - if err := apiProvider.ReportTappedPods(tapperSyncer.CurrentlyTappedPods); err != nil { + if err := connector.ReportTappedPods(tapperSyncer.CurrentlyTappedPods); err != nil { log.Printf("[Error] failed update tapped pods %v", err) } case tapperStatus, ok := <-tapperSyncer.TapperStatusChangedOut: @@ -195,7 +195,7 @@ func startTapperSyncer(ctx context.Context, cancel context.CancelFunc, provider log.Print("kubesharkTapperSyncer tapper status changed channel closed, ending listener loop") return } - if err := apiProvider.ReportTapperStatus(tapperStatus); err != nil { + if err := connector.ReportTapperStatus(tapperStatus); err != nil { log.Printf("[Error] failed update tapper status %v", err) } case <-ctx.Done():