exec.Stream() -> exec.StreamWithContext()

rabbitmq · Jan 2, 2024 · 8709ebe · 8709ebe
1 parent 697ab71
commit 8709ebe
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/controllers/pod_executor.go b/controllers/pod_executor.go
@@ -3,6 +3,7 @@ package controllers
 import (
 	"bufio"
 	"bytes"
+	"context"
 
 	corev1 "k8s.io/api/core/v1"
 	"k8s.io/client-go/kubernetes"
@@ -42,7 +43,7 @@ func (p *rabbitmqPodExecutor) Exec(clientset *kubernetes.Clientset, clusterConfi
 	stdOut := bytes.Buffer{}
 	stdErr := bytes.Buffer{}
 
-	err = exec.Stream(remotecommand.StreamOptions{
+	err = exec.StreamWithContext(context.TODO(), remotecommand.StreamOptions{
 		Stdout: bufio.NewWriter(&stdOut),
 		Stderr: bufio.NewWriter(&stdErr),
 		Stdin:  nil,