SCFF-5 changed the default values for Log Events Batch Size and Sumo Post Minimum delay. Queue count Log modified

Author: nmillalaf

main.go

@@ -29,8 +29,8 @@ 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
-	eventsBatchSize      = kingpin.Flag("log-events-batch-size", "Log Events Batch Size").OverrideDefaultFromEnvar("LOG_EVENTS_BATCH_SIZE").Default("10").Int()
-	sumoPostMinimumDelay = kingpin.Flag("sumo-post-minimum-delay", "Sumo Post Minimum Delay").OverrideDefaultFromEnvar("SUMO_POST_MINIMUM_DELAY").Default("500ms").Duration()
+	eventsBatchSize      = kingpin.Flag("log-events-batch-size", "Log Events Batch Size").OverrideDefaultFromEnvar("LOG_EVENTS_BATCH_SIZE").Int()
+	sumoPostMinimumDelay = kingpin.Flag("sumo-post-minimum-delay", "Sumo Post Minimum Delay").OverrideDefaultFromEnvar("SUMO_POST_MINIMUM_DELAY").Duration()
 )
 
 var (
@@ -54,7 +54,6 @@ func main() {
 	logging.Info.Println("Cloudfoundry User: " + *user)
 
 	logging.Info.Printf("Events Batch Size: [%d]\n", *eventsBatchSize)
-	/**/ fmt.Println(*sumoPostMinimumDelay)
 	logging.Info.Println("Starting firehose-to-sumo " + version)
 
 	c := cfclient.Config{

manifest.yml

@@ -7,5 +7,5 @@ env:
   FIREHOSE_SUBSCRIPTION_ID: firehose-to-sumologic
   CLOUDFOUNDRY_USER: admin
   CLOUDFOUNDRY_PASSWORD: admin
-  LOG_EVENTS_BATCHSIZE: 11
-  SUMO_POST_MINIMUM_DELAY: 501ms
+  LOG_EVENTS_BATCHSIZE: 200
+  SUMO_POST_MINIMUM_DELAY: 200ms

sumoCFFirehose/sumoLogicAppender.go

@@ -55,8 +55,7 @@ func (s *SumoLogicAppender) Start() {
 	Buffer.timerIdlebuffer = time.Now()
 	logging.Info.Println("Starting Appender Worker")
 	for {
-		logging.Info.Println("Log queue size: ")
-		logging.Info.Println(s.nozzleQueue.GetCount())
+		logging.Info.Printf("Log queue size: %d", s.nozzleQueue.GetCount())
 		if s.nozzleQueue.GetCount() == 0 {
 			logging.Trace.Println("Waiting for 300 ms")
 			time.Sleep(300 * time.Millisecond)