SCFF-30 changed eventBatchSize and if condition appender

Author: nmillalaf

main.go

@@ -28,7 +28,7 @@ var (
 	wantedEvents      = kingpin.Flag("events", fmt.Sprintf("Comma separated list of events you would like. Valid options are %s", eventRouting.GetListAuthorizedEventEvents())).Default("LogMessage").OverrideDefaultFromEnvar("EVENTS").String()
 	boltDatabasePath  = "my.db"                   //default
 	tickerTime, errT  = time.ParseDuration("60s") //Default
-	eventsBatch       = kingpin.Flag("event-amount", "Events amount").Int()
+	eventsBatchSize   = kingpin.Flag("event-amount", "Events amount").Int()
 )
 
 var (
@@ -66,7 +66,7 @@ func main() {
 
 	//Creating queue
 	queue := eventQueue.NewQueue(make([]*eventQueue.Node, 100))
-	loggingClientSumo := sumoCFFirehose.NewSumoLogicAppender(*sumoEndpoint, 1000, *queue, *eventsBatch)
+	loggingClientSumo := sumoCFFirehose.NewSumoLogicAppender(*sumoEndpoint, 1000, *queue, *eventsBatchSize)
 
 	//Creating Events
 	events := eventRouting.NewEventRouting(cachingClient, *loggingClientSumo, *queue)

sumoCFFirehose/sumoLogicAppender.go

@@ -15,16 +15,16 @@ type SumoLogicAppender struct {
 	connectionTimeout int //10000
 	httpClient        http.Client
 	nozzleQueue       eventQueue.Queue
-	eventsBatch       int
+	eventsBatchSize   int
 }
 
-func NewSumoLogicAppender(urlValue string, connectionTimeoutValue int, nozzleQueue eventQueue.Queue, eventsBatch int) *SumoLogicAppender {
+func NewSumoLogicAppender(urlValue string, connectionTimeoutValue int, nozzleQueue eventQueue.Queue, eventsBatchSize int) *SumoLogicAppender {
 	return &SumoLogicAppender{
 		url:               urlValue,
 		connectionTimeout: connectionTimeoutValue,
 		httpClient:        http.Client{Timeout: time.Duration(connectionTimeoutValue * int(time.Millisecond))},
 		nozzleQueue:       nozzleQueue,
-		eventsBatch:       eventsBatch,
+		eventsBatchSize:   eventsBatchSize,
 	}
 }
 
@@ -64,7 +64,7 @@ func StringBuilder(queue eventQueue.Queue) string {
 
 func (s *SumoLogicAppender) AppendLogs(queue eventQueue.Queue) {
 	// the appender calls for the next message in the queue and parse it to a string
-	if queue.GetCount() == s.eventsBatch { //whent the batch limit is met, call stringBuilder
+	if queue.GetCount() > s.eventsBatchSize { //whent the batch limit is met, call stringBuilder
 		logMessage := StringBuilder(queue)
 		s.SendToSumo(logMessage)
 	}