Log worker benchmark results when all info is collected

mulbc · Jun 28, 2020 · 6787c06 · 6787c06
1 parent 9fe2c1a
commit 6787c06
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 2 deletions.
diff --git a/go.mod b/go.mod
@@ -7,7 +7,7 @@ require (
 	github.com/aws/aws-sdk-go v1.32.1
 	github.com/prometheus/client_golang v1.6.0
 	github.com/prometheus/client_model v0.2.0
-	github.com/prometheus/common v0.10.0
+	github.com/prometheus/common v0.10.0 // indirect
 	github.com/sirupsen/logrus v1.6.0
 	go.opencensus.io v0.22.3
 	gopkg.in/yaml.v2 v2.3.0

diff --git a/worker/main.go b/worker/main.go
@@ -104,6 +104,7 @@ func connectToServer(serverAddress string) error {
 			benchResults := getCurrentPromValues(config.Test.Name)
 			benchResults.Duration = duration
 			benchResults.Bandwidth = benchResults.Bytes / duration.Seconds()
+			log.Infof("PROM VALUES %+v", benchResults)
 			_ = encoder.Encode(common.WorkerMessage{Message: "work done", BenchResult: benchResults})
 			// Work is done - return to being a ready worker by reconnecting
 			return nil

diff --git a/worker/prometheus.go b/worker/prometheus.go
@@ -106,7 +106,6 @@ func getCurrentPromValues(testName string) common.BenchmarkResult {
 	benchResult.Operations = sumCounterForTest(resultmap["gosbench_finished_ops"], testName)
 	benchResult.Bytes = sumCounterForTest(resultmap["gosbench_uploaded_bytes"], testName) + sumCounterForTest(resultmap["gosbench_downloaded_bytes"], testName)
 	benchResult.LatencyAvg = averageHistogramForTest(resultmap["gosbench_ops_latency"], testName)
-	log.Infof("PROM VALUES %+v", benchResult)
 	return benchResult
 }