feat(testworkflows): increase buffer size for logs buffering

kubeshop · Jul 10, 2024 · 5ff180f · 5ff180f
1 parent ead5e95
commit 5ff180f
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pkg/testworkflows/testworkflowcontroller/logs.go b/pkg/testworkflows/testworkflowcontroller/logs.go
@@ -23,6 +23,7 @@ import (
 
 const (
 	FlushLogMaxSize = 100_000
+	FlushBufferSize = 65_536
 	FlushLogTime    = 100 * time.Millisecond
 )
 
@@ -218,7 +219,7 @@ func WatchContainerLogs(parentCtx context.Context, clientSet kubernetes.Interfac
 		defer flushLogBuffer()
 
 		// Parse and return the logs
-		reader := bufio.NewReader(stream)
+		reader := bufio.NewReaderSize(stream, FlushBufferSize)
 		tsReader := newTimestampReader()
 		isNewLine := false
 		isStarted := false