Added t.parallel() to logger_test.go functions and used goroutines in logger.go LogMatcher function

Signed-off-by: Insomniac2904 <[email protected]>

Author: Insomniac2904

pkg/testutils/logger.go

@@ -93,18 +93,30 @@ func (b *Buffer) Write(p []byte) (int, error) {
 	return b.Buffer.Write(p)
 }
 
-// LogMatcher is a helper func that returns true if the subStr appears more than 'occurrences' times in the logs.
 var LogMatcher = func(occurrences int, subStr string, logs []string) (bool, string) {
 	errMsg := fmt.Sprintf("subStr '%s' does not occur %d time(s) in %v", subStr, occurrences, logs)
 	if len(logs) < occurrences {
 		return false, errMsg
 	}
+
+	// Count occurrences in parallel
 	var count int
+	var wg sync.WaitGroup
+	var mu sync.Mutex
+
 	for _, log := range logs {
-		if strings.Contains(log, subStr) {
-			count++
-		}
+		wg.Add(1)
+		go func(log string) {
+			defer wg.Done()
+			if strings.Contains(log, subStr) {
+				mu.Lock()
+				count++
+				mu.Unlock()
+			}
+		}(log)
 	}
+	wg.Wait()
+
 	if count >= occurrences {
 		return true, ""
 	}

pkg/testutils/logger_test.go

@@ -14,6 +14,7 @@ import (
 )
 
 func TestNewLogger(t *testing.T) {
+	t.Parallel()
 	logger, log := NewLogger()
 	logger.Warn("hello", zap.String("x", "y"))
 
@@ -26,11 +27,13 @@ func TestNewLogger(t *testing.T) {
 }
 
 func TestNewEchoLogger(t *testing.T) {
+	t.Parallel()
 	logger, _ := NewEchoLogger(t)
 	logger.Warn("hello", zap.String("x", "y"))
 }
 
 func TestJSONLineError(t *testing.T) {
+	t.Parallel()
 	log := &Buffer{}
 	log.WriteString("bad-json\n")
 	_, ok := log.JSONLine(0)["error"]
@@ -64,6 +67,7 @@ func TestRaceCondition(*testing.T) {
 }
 
 func TestLogMatcher(t *testing.T) {
+	t.Parallel()
 	tests := []struct {
 		occurrences int
 		subStr      string
@@ -80,6 +84,7 @@ func TestLogMatcher(t *testing.T) {
 	for i, tt := range tests {
 		test := tt
 		t.Run(fmt.Sprintf("%v", i), func(t *testing.T) {
+			t.Parallel()
 			match, errMsg := LogMatcher(test.occurrences, test.subStr, test.logs)
 			assert.Equal(t, test.expected, match)
 			assert.Equal(t, test.errMsg, errMsg)