Lint

Author: duhminick

plugins/outputs/cloudwatchlogs/internal/pusher/target_test.go

@@ -259,7 +259,7 @@ func TestDescribeLogGroupsBatching(t *testing.T) {
 
 	t.Run("ProcessBatchOnLimit", func(t *testing.T) {
 		mockService := new(mockLogsService)
-		
+
 		// Setup mock to expect a batch of 50 log groups
 		mockService.On("DescribeLogGroups", mock.MatchedBy(func(input *cloudwatchlogs.DescribeLogGroupsInput) bool {
 			return len(input.LogGroupIdentifiers) == logGroupIdentifierLimit
@@ -269,7 +269,7 @@ func TestDescribeLogGroupsBatching(t *testing.T) {
 
 		manager := NewTargetManager(logger, mockService)
 		tm := manager.(*targetManager)
-		
+
 		for i := 0; i < logGroupIdentifierLimit; i++ {
 			target := Target{
 				Group:     fmt.Sprintf("group-%d", i),
@@ -278,15 +278,15 @@ func TestDescribeLogGroupsBatching(t *testing.T) {
 			}
 			tm.dlg <- target
 		}
-		
+
 		time.Sleep(100 * time.Millisecond)
-		
+
 		mockService.AssertExpectations(t)
 	})
 
 	t.Run("ProcessBatchOnTimer", func(t *testing.T) {
 		mockService := new(mockLogsService)
-		
+
 		// Setup mock to expect a batch of less than 50 log groups
 		mockService.On("DescribeLogGroups", mock.MatchedBy(func(input *cloudwatchlogs.DescribeLogGroupsInput) bool {
 			return len(input.LogGroupIdentifiers) == 5
@@ -296,7 +296,7 @@ func TestDescribeLogGroupsBatching(t *testing.T) {
 
 		manager := NewTargetManager(logger, mockService)
 		tm := manager.(*targetManager)
-		
+
 		for i := 0; i < 5; i++ {
 			target := Target{
 				Group:     fmt.Sprintf("group-%d", i),
@@ -305,16 +305,16 @@ func TestDescribeLogGroupsBatching(t *testing.T) {
 			}
 			tm.dlg <- target
 		}
-		
+
 		// Wait for ticker to fire (slightly longer than 5 seconds)
 		time.Sleep(5100 * time.Millisecond)
-		
+
 		mockService.AssertExpectations(t)
 	})
 
 	t.Run("ProcessBatchInvalidGroups", func(t *testing.T) {
 		mockService := new(mockLogsService)
-		
+
 		// Return empty  result
 		mockService.On("DescribeLogGroups", mock.Anything).Return(&cloudwatchlogs.DescribeLogGroupsOutput{
 			LogGroups: []*cloudwatchlogs.LogGroup{},
@@ -333,10 +333,10 @@ func TestDescribeLogGroupsBatching(t *testing.T) {
 
 		mockService.AssertNotCalled(t, "PutRetentionPolicy")
 	})
-	
+
 	t.Run("RetentionPolicyUpdate", func(t *testing.T) {
 		mockService := new(mockLogsService)
-		
+
 		mockService.On("DescribeLogGroups", mock.Anything).Return(&cloudwatchlogs.DescribeLogGroupsOutput{
 			LogGroups: []*cloudwatchlogs.LogGroup{
 				{
@@ -349,29 +349,29 @@ func TestDescribeLogGroupsBatching(t *testing.T) {
 				},
 			},
 		}, nil).Once()
-		
+
 		// Setup mock for PutRetentionPolicy (should only be called for group-1)
 		mockService.On("PutRetentionPolicy", mock.MatchedBy(func(input *cloudwatchlogs.PutRetentionPolicyInput) bool {
 			return *input.LogGroupName == "group-1" && *input.RetentionInDays == 7
 		})).Return(&cloudwatchlogs.PutRetentionPolicyOutput{}, nil).Once()
 
 		manager := NewTargetManager(logger, mockService)
 		tm := manager.(*targetManager)
-		
+
 		// Create a batch with two targets, one needing retention update
 		batch := make(map[string]Target)
 		batch["group-1"] = Target{Group: "group-1", Stream: "stream", Retention: 7}
 		batch["group-2"] = Target{Group: "group-2", Stream: "stream", Retention: 7}
-		
+
 		tm.updateTargetBatch(batch)
 		time.Sleep(100 * time.Millisecond)
-		
+
 		mockService.AssertExpectations(t)
 	})
-	
+
 	t.Run("BatchRetryOnError", func(t *testing.T) {
 		mockService := new(mockLogsService)
-		
+
 		// Setup mock to fail once then succeed
 		mockService.On("DescribeLogGroups", mock.Anything).
 			Return(&cloudwatchlogs.DescribeLogGroupsOutput{}, fmt.Errorf("internal error")).Once()
@@ -382,15 +382,15 @@ func TestDescribeLogGroupsBatching(t *testing.T) {
 
 		manager := NewTargetManager(logger, mockService)
 		tm := manager.(*targetManager)
-		
+
 		// Create a batch with one target
 		batch := make(map[string]Target)
 		batch["group-1"] = Target{Group: "group-1", Stream: "stream", Retention: 7}
-		
+
 		tm.updateTargetBatch(batch)
 		// Sleep enough for retry
 		time.Sleep(2 * time.Second)
-		
+
 		mockService.AssertExpectations(t)
 	})
 }