hec batch size and perf.py enhancement based on perf testing result

Author: chenziliang

ci/perf.py

@@ -101,7 +101,9 @@ def execute(cmd, duration):
 def run_trafficcontroller(duration):
     for suite in nozzle_perf_suites:
         for case in suite["cases"]:
-            ip = "pcf_{}".format("_".join("{}-{}".format(k, v) for k, v in case.iteritems()))
+            ip = "pcf_{}_{}".format(
+                suite["message-type"],
+                "_".join("{}-{}".format(k, v) for k, v in case.iteritems()))
             cmd = [
                 "./trafficcontroller",
                 "--config", "loggregator_trafficcontroller.json",

splunknozzle/config.go

@@ -116,7 +116,7 @@ func NewConfigFromCmdFlags(version, branch, commit, buildos string) *Config {
 	kingpin.Flag("consumer-queue-size", "Consumer queue buffer size").
 		OverrideDefaultFromEnvar("CONSUMER_QUEUE_SIZE").Default("10000").IntVar(&c.QueueSize)
 	kingpin.Flag("hec-batch-size", "Batchsize of the events pushing to HEC").
-		OverrideDefaultFromEnvar("HEC_BATCH_SIZE").Default("1000").IntVar(&c.BatchSize)
+		OverrideDefaultFromEnvar("HEC_BATCH_SIZE").Default("100").IntVar(&c.BatchSize)
 	kingpin.Flag("hec-retries", "Number of retries before dropping events").
 		OverrideDefaultFromEnvar("HEC_RETRIES").Default("5").IntVar(&c.Retries)
 	kingpin.Flag("hec-workers", "How many workers (concurrency) when post data to HEC").