Flush logger after a command is done executing (#85)

Signed-off-by: Andreas Neumann <[email protected]>

pkg/test/utils/kubernetes.go

@@ -1020,6 +1020,9 @@ func RunCommands(logger Logger, namespace string, command string, commands []har
 		}
 		if bg != nil {
 			bgs = append(bgs, bg)
+		} else {
+			// We only need to flush if this is not a background command
+			logger.Flush()
 		}
 	}
 

pkg/test/utils/logger.go

@@ -13,6 +13,7 @@ type Logger interface {
 	Logf(format string, args ...interface{})
 	WithPrefix(string) Logger
 	Write(p []byte) (n int, err error)
+	Flush()
 }
 
 // TestLogger implements the Logger interface to be compatible with the go test operator's
@@ -65,3 +66,10 @@ func (t *TestLogger) Write(p []byte) (n int, err error) {
 
 	return len(p), nil
 }
+
+func (t *TestLogger) Flush() {
+	if len(t.buffer) != 0 {
+		t.Log(string(t.buffer))
+		t.buffer = []byte{}
+	}
+}