test: reset the log recorder after each test to enable tests with log…

… recording to share an environment;

pkg/test/env/environment.go

@@ -173,6 +173,10 @@ func (e *Environment) Logs() LogRecords {
 	return e.logger.Records()
 }
 
+func (e *Environment) ResetLogs() {
+	e.logger.Reset()
+}
+
 func (e *Environment) Clock() clock.Clock {
 	return clock.Provider
 }

pkg/test/env/logging.go

@@ -20,6 +20,7 @@ type (
 	RecordingLogger interface {
 		log.GosoLogger
 		Records() []LogRecord
+		Reset()
 	}
 
 	recordingLogger struct {
@@ -102,6 +103,13 @@ func (r recordingLogger) Records() []LogRecord {
 	return records
 }
 
+func (r recordingLogger) Reset() {
+	r.mutex.RLock()
+	defer r.mutex.RUnlock()
+
+	*r.records = []LogRecord{}
+}
+
 func (h handlerInMemoryWriter) Channels() []string {
 	return []string{}
 }

pkg/test/suite/run.go

@@ -171,6 +171,7 @@ func runTestCaseWithSharedEnvironment(t *testing.T, suite TestingSuite, suiteOpt
 		stream.ResetInMemoryInputs()
 		stream.ResetInMemoryOutputs()
 		stream.ResetProducerDaemons()
+		environment.ResetLogs()
 	}
 }