show logs of "minio" pod (#1578)

minio · Apr 21, 2023 · e76286c · e76286c
1 parent dbaa2a2
commit e76286c
Showing 1 changed file with 13 additions and 3 deletions.
diff --git a/api/pod-handlers.go b/api/pod-handlers.go
@@ -24,6 +24,7 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
+	"io"
 	"sort"
 	"time"
 
@@ -100,13 +101,22 @@ func getPodLogsResponse(session *models.Principal, params operator_api.GetPodLog
 	if err != nil {
 		return "", ErrorWithContext(ctx, err)
 	}
-	listOpts := &corev1.PodLogOptions{}
+	listOpts := &corev1.PodLogOptions{Container: "minio"}
 	logs := clientset.CoreV1().Pods(params.Namespace).GetLogs(params.PodName, listOpts)
-	buff, err := logs.DoRaw(ctx)
+
+	buffLogs, err := logs.Stream(ctx)
+	if err != nil {
+		return "", ErrorWithContext(ctx, err)
+	}
+
+	defer buffLogs.Close()
+
+	buf := new(bytes.Buffer)
+	_, err = io.Copy(buf, buffLogs)
 	if err != nil {
 		return "", ErrorWithContext(ctx, err)
 	}
-	return string(buff), nil
+	return buf.String(), nil
 }
 
 func getTenantPodsResponse(session *models.Principal, params operator_api.GetTenantPodsParams) ([]*models.TenantPod, *models.Error) {