Skip to content

Commit 1afaed3

Browse files
committed
SCFF-7 passing a log string to the sendig to sumo method
1 parent 55919be commit 1afaed3

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

sumoCFFirehose/sumoLogicAppender.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ func (s *SumoLogicAppender) Start() {
6262

6363
if time.Since(Buffer.timerIdlebuffer).Seconds() >= 10 && Buffer.logEventsInCurrentBuffer > 0 {
6464
logging.Info.Println("Sending current batch of logs after timer exceeded limit")
65-
go s.SendToSumo(Buffer)
65+
go s.SendToSumo(Buffer.logStringToSend.String())
6666
Buffer = newBuffer()
6767
Buffer.timerIdlebuffer = time.Now()
6868
continue
@@ -78,7 +78,7 @@ func (s *SumoLogicAppender) Start() {
7878
s.AppendLogs(&Buffer)
7979
Buffer.timerIdlebuffer = time.Now()
8080
}
81-
go s.SendToSumo(Buffer)
81+
go s.SendToSumo(Buffer.logStringToSend.String())
8282
Buffer = newBuffer()
8383
} else {
8484
logging.Trace.Println("Pushing Logs to Buffer: ")
@@ -113,11 +113,11 @@ func (s *SumoLogicAppender) AppendLogs(buffer *SumoBuffer) {
113113

114114
}
115115

116-
func (s *SumoLogicAppender) SendToSumo(buffer SumoBuffer) {
116+
func (s *SumoLogicAppender) SendToSumo(logStringToSend string) {
117117

118118
var buf bytes.Buffer
119119
g := gzip.NewWriter(&buf)
120-
g.Write(buffer.logStringToSend.Bytes())
120+
g.Write([]byte(logStringToSend))
121121
g.Close()
122122

123123
for time.Since(s.timerBetweenPost) < s.sumoPostMinimumDelay {

0 commit comments

Comments
 (0)