Only init queueLatency observer once to avoid data race

Financial-Times · Sep 17, 2018 · 2c6f357 · 2c6f357
1 parent 1d26dfd
commit 2c6f357
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/processor.go b/processor.go
@@ -42,7 +42,9 @@ type logProcessor struct {
 var queueLatency prometheus.Observer
 
 func NewLogProcessor(forwarder Forwarder, cache Cache, config appConfig) LogProcessor {
-	queueLatency = registerHistogram("queue_latency", "Post queue latency", []float64{.00001, .000015, .00002, .000025, .00003, .00004, .00005, .00006})
+	if queueLatency != nil {
+		queueLatency = registerHistogram("queue_latency", "Post queue latency", []float64{.00001, .000015, .00002, .000025, .00003, .00004, .00005, .00006})
+	}
 	return &logProcessor{forwarder: forwarder, cache: cache, wg: sync.WaitGroup{}, chanBuffer: config.chanBuffer, workers: config.workers}
 }