From 9f3cbc7d39def4f1b8e0ae87abf7c238937c147d Mon Sep 17 00:00:00 2001
From: luoyuLianga <yuluo19851227@gmail.com>
Date: Thu, 29 Aug 2024 20:46:17 +0800
Subject: [PATCH] feat: Add rate limiting flag.

---
 logs/sender/batch_strategy.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/logs/sender/batch_strategy.go b/logs/sender/batch_strategy.go
index 7e387cfc..0e5bfa94 100644
--- a/logs/sender/batch_strategy.go
+++ b/logs/sender/batch_strategy.go
@@ -108,6 +108,10 @@ func (s *batchStrategy) processMessage(m *message.Message, outputChan chan *mess
 	}
 	added := s.buffer.AddMessage(m)
 	if !added || s.buffer.IsFull() {
+		if s.buffer.IsFull() {
+			log.Printf("I! buffer full len: %d, size: %d",
+				len(s.buffer.messageBuffer), s.buffer.contentSize)
+		}
 		s.flushBuffer(outputChan, send)
 	}
 	if !added {