Fix concurrency issues in emf exporter (#2571)

Author: bjrara

exporter/awsemfexporter/cwlog_client_test.go

@@ -32,14 +32,14 @@ import (
 	"go.uber.org/zap"
 )
 
-func NewAlwaysPassMockLogClient() LogClient {
+func NewAlwaysPassMockLogClient(putLogEventsFunc func(args mock.Arguments)) LogClient {
 	logger := zap.NewNop()
 	svc := new(mockCloudWatchLogsClient)
 
 	svc.On("PutLogEvents", mock.Anything).Return(
 		&cloudwatchlogs.PutLogEventsOutput{
 			NextSequenceToken: &expectedNextSequenceToken},
-		nil)
+		nil).Run(putLogEventsFunc)
 
 	svc.On("CreateLogGroup", mock.Anything).Return(new(cloudwatchlogs.CreateLogGroupOutput), nil)
 

exporter/awsemfexporter/metric_translator.go

@@ -315,7 +315,7 @@ func translateCWMetricToEMF(cWMetric *CWMetrics) *LogEvent {
 	}
 
 	metricCreationTime := cWMetric.TimestampMs
-	logEvent := NewLogEvent(
+	logEvent := newLogEvent(
 		metricCreationTime,
 		string(pleMsg),
 	)