Skip to content

Commit 98bdc89

Browse files
committed
style(pusher): Fix unused parameter lint warnings
🤖 Assisted by AI
1 parent b6f3b3e commit 98bdc89

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -42,14 +42,14 @@ func TestPoisonPillScenario(t *testing.T) {
4242
// Configure mock service responses with realistic latency
4343
mockService.On("PutLogEvents", mock.MatchedBy(func(input *cloudwatchlogs.PutLogEventsInput) bool {
4444
return *input.LogGroupName == "log-stream-ple-access-granted"
45-
})).Return(&cloudwatchlogs.PutLogEventsOutput{}, nil).Run(func(args mock.Arguments) {
45+
})).Return(&cloudwatchlogs.PutLogEventsOutput{}, nil).Run(func(_ mock.Arguments) {
4646
time.Sleep(10 * time.Millisecond) // Simulate API latency
4747
allowedGroupSuccessCount.Add(1)
4848
})
4949

5050
mockService.On("PutLogEvents", mock.MatchedBy(func(input *cloudwatchlogs.PutLogEventsInput) bool {
5151
return *input.LogGroupName != "log-stream-ple-access-granted"
52-
})).Return((*cloudwatchlogs.PutLogEventsOutput)(nil), accessDeniedErr).Run(func(args mock.Arguments) {
52+
})).Return((*cloudwatchlogs.PutLogEventsOutput)(nil), accessDeniedErr).Run(func(_ mock.Arguments) {
5353
time.Sleep(10 * time.Millisecond) // Simulate API latency
5454
deniedGroupAttemptCount.Add(1)
5555
})
@@ -177,7 +177,7 @@ func TestSingleDeniedLogGroup(t *testing.T) {
177177

178178
mockService.On("PutLogEvents", mock.MatchedBy(func(input *cloudwatchlogs.PutLogEventsInput) bool {
179179
return *input.LogGroupName == "log-stream-ple-access-granted"
180-
})).Return(&cloudwatchlogs.PutLogEventsOutput{}, nil).Run(func(args mock.Arguments) {
180+
})).Return(&cloudwatchlogs.PutLogEventsOutput{}, nil).Run(func(_ mock.Arguments) {
181181
allowedGroupSuccessCount.Add(1)
182182
})
183183

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ func TestRetryHeapProcessorExpiredBatchShouldResume(t *testing.T) {
2121

2222
var sendAttempts atomic.Int32
2323
mockService := &stubLogsService{
24-
ple: func(input *cloudwatchlogs.PutLogEventsInput) (*cloudwatchlogs.PutLogEventsOutput, error) {
24+
ple: func(_ *cloudwatchlogs.PutLogEventsInput) (*cloudwatchlogs.PutLogEventsOutput, error) {
2525
sendAttempts.Add(1)
2626
// Always fail to simulate a problematic target
2727
return nil, &cloudwatchlogs.ServiceUnavailableException{}

0 commit comments

Comments
 (0)