Changing the agent health payload for log events to be the buffered s…

…ize of the request (#214)
aws · May 31, 2023 · 5ee4ecd · 5ee4ecd
1 parent c1bd317
commit 5ee4ecd
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/plugins/outputs/cloudwatchlogs/pusher.go b/plugins/outputs/cloudwatchlogs/pusher.go
@@ -239,7 +239,7 @@ func (p *pusher) send() {
 		input.SequenceToken = p.sequenceToken
 		opStartTime := time.Now()
 		output, err := p.Service.PutLogEvents(input)
-		p.agentInfo.RecordOpData(time.Since(opStartTime), len(input.LogEvents), err)
+		p.agentInfo.RecordOpData(time.Since(opStartTime), p.bufferredSize, err)
 		if err == nil {
 			if output.NextSequenceToken != nil {
 				p.sequenceToken = output.NextSequenceToken