Merge pull request #89 from KevinPike/concurrenyInUse-statsd

Add statsd metric for concurrencyInUse
afex · May 2, 2018 · fa1af6a · fa1af6a
2 parents b6b54cf + 0a5b890
commit fa1af6a
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/plugins/statsd_collector.go b/plugins/statsd_collector.go
@@ -30,6 +30,7 @@ type StatsdCollector struct {
 	deadlinePrefix          string
 	totalDurationPrefix     string
 	runDurationPrefix       string
+	concurrencyInUsePrefix  string
 	sampleRate              float32
 }
 
@@ -109,6 +110,7 @@ func (s *StatsdCollectorClient) NewStatsdCollector(name string) metricCollector.
 		deadlinePrefix:          name + ".contextDeadlineExceeded",
 		totalDurationPrefix:     name + ".totalDuration",
 		runDurationPrefix:       name + ".runDuration",
+		concurrencyInUsePrefix:  name + ".concurrencyInUse",
 		sampleRate:              s.sampleRate,
 	}
 }
@@ -137,6 +139,13 @@ func (g *StatsdCollector) updateTimerMetric(prefix string, dur time.Duration) {
 	}
 }
 
+func (g *StatsdCollector) updateTimingMetric(prefix string, i int64) {
+	err := g.client.Timing(prefix, i, g.sampleRate)
+	if err != nil {
+		log.Printf("Error sending statsd metrics %s", prefix)
+	}
+}
+
 func (g *StatsdCollector) Update(r metricCollector.MetricResult) {
 	if r.Successes > 0 {
 		g.setGauge(g.circuitOpenPrefix, 0)
@@ -157,6 +166,7 @@ func (g *StatsdCollector) Update(r metricCollector.MetricResult) {
 	g.incrementCounterMetric(g.deadlinePrefix, r.ContextDeadlineExceeded)
 	g.updateTimerMetric(g.totalDurationPrefix, r.TotalDuration)
 	g.updateTimerMetric(g.runDurationPrefix, r.RunDuration)
+	g.updateTimingMetric(g.concurrencyInUsePrefix, int64(100*r.ConcurrencyInUse))
 }
 
 // Reset is a noop operation in this collector.