Option.StdOutEnabled to control forwarder logs

Signed-off-by: hfuss <[email protected]>

const.go

@@ -24,18 +24,20 @@ type carry struct {
 }
 
 type PodOption struct {
-	LocalPort int    // the local port for forwarding
-	PodPort   int    // the k8s pod port
-	Pod       v1.Pod // the k8s pod metadata
+	LocalPort     int    // the local port for forwarding
+	PodPort       int    // the k8s pod port
+	Pod           v1.Pod // the k8s pod metadata
+	StdOutEnabled bool
 }
 
 type Option struct {
-	LocalPort   int    // the local port for forwarding
-	RemotePort  int    // the remote port port for forwarding
-	Namespace   string // the k8s namespace metadata
-	PodName     string // the k8s pod metadata
-	ServiceName string // the k8s service metadata
-	Source      string // the k8s source string, eg: svc/my-nginx-svc po/my-nginx-66b6c48dd5-ttdb2
+	LocalPort     int    // the local port for forwarding
+	RemotePort    int    // the remote port port for forwarding
+	Namespace     string // the k8s namespace metadata
+	PodName       string // the k8s pod metadata
+	ServiceName   string // the k8s service metadata
+	Source        string // the k8s source string, eg: svc/my-nginx-svc po/my-nginx-66b6c48dd5-ttdb2
+	StdOutEnabled bool   // whether to output the forward logs to stdout or not
 }
 
 type Result struct {

forwarder.go

@@ -71,12 +71,6 @@ func forwarders(ctx context.Context, options []*Option, config *restclient.Confi
 		return nil, err
 	}
 
-	stream := genericclioptions.IOStreams{
-		In:     os.Stdin,
-		Out:    os.Stdout,
-		ErrOut: os.Stderr,
-	}
-
 	carries := make([]*carry, len(podOptions))
 
 	var g errgroup.Group
@@ -86,6 +80,16 @@ func forwarders(ctx context.Context, options []*Option, config *restclient.Confi
 		stopCh := make(chan struct{}, 1)
 		readyCh := make(chan struct{})
 
+		stream := genericclioptions.IOStreams{
+			In:     os.Stdin,
+			ErrOut: os.Stderr,
+		}
+
+		stream.Out = os.DevNull
+		if option.StdOutEnabled {
+			stream.Out = os.Stdout
+		}
+
 		req := &portForwardAPodRequest{
 			RestConfig: config,
 			Pod:        option.Pod,

utils.go

@@ -140,5 +140,6 @@ func buildPodOption(option *Option, pod *v1.Pod) *PodOption {
 				Namespace: pod.Namespace,
 			},
 		},
+		StdOutEnabled: option.StdOutEnabled,
 	}
 }