1 parent 858a2e7 commit 87bc0c0Copy full SHA for 87bc0c0
1 file changed
sumoCFFirehose/sumoLogicAppender.go
@@ -43,15 +43,14 @@ func (s *SumoLogicAppender) Start() {
43
timer = time.Now() //reset timer
44
if s.logEventsInCurrentBuffer == s.eventsBatchSize { //if buffer is full, send logs to sumo
45
logging.Trace.Println("Batch Size complete")
46
- s.SendToSumo(s.logStringToSend)
47
break
48
} else if time.Since(timer).Seconds() >= 10 { // else if timer is up, send existing logs to sumo
49
logging.Trace.Println("Sending current batch of logs after timer exceeded limit")
50
51
- timer = time.Now() //reset timer
52
53
}
54
+ s.SendToSumo(s.logStringToSend)
+ timer = time.Now() //reset timer
55
56
57
0 commit comments