make statsD metric name consistent with kanaloa fix #136

iheartradio · Aug 12, 2016 · f6422ef · f6422ef
1 parent 9c620e4
commit f6422ef
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 8 deletions.
diff --git a/core/src/main/scala/kanaloa/reactive/dispatcher/metrics/StatsDReporter.scala b/core/src/main/scala/kanaloa/reactive/dispatcher/metrics/StatsDReporter.scala
@@ -43,16 +43,16 @@ class StatsDReporter(
   val failureSampleRate: Double = 1.0
 
   def report(metric: Metric): Unit = metric match {
-    case WorkReceived ⇒ increment("queue.enqueued")
-    case WorkRejected ⇒ increment("queue.enqueueRejected", Math.min(1d, eventSampleRate * 3d))
+    case WorkReceived ⇒ increment("work.received")
+    case WorkRejected ⇒ increment("work.rejected", Math.min(1d, eventSampleRate * 3d))
 
     case WorkCompleted(processTime) ⇒
       increment("work.completed")
-      statsd.timing("queue.avgProcessTime", processTime.toMillis.toInt, eventSampleRate)
+      statsd.timing("work.processTime", processTime.toMillis.toInt, eventSampleRate)
 
     case WorkFailed           ⇒ increment("work.failed", failureSampleRate)
     case WorkTimedOut         ⇒ increment("work.timedOut", failureSampleRate)
-    case CircuitBreakerOpened ⇒ increment("queue.circuitBreakerOpened", failureSampleRate)
+    case CircuitBreakerOpened ⇒ increment("worker.circuitBreakerOpened", failureSampleRate)
 
     case PoolSize(size) ⇒
       gauge("pool.size", size)

diff --git a/grafana/dashboard.json b/grafana/dashboard.json
@@ -212,11 +212,11 @@
           "steppedLine": false,
           "targets": [
             {
-              "target": "aliasSub(stats.counters.$namespace.$dispatcherName.queue.enqueued.rate, '.*$namespace.(.*).queue.enqueued.rate', '\\1 (accepted)')",
+              "target": "aliasSub(stats.counters.$namespace.$dispatcherName.work.received.rate, '.*$namespace.(.*).work.received.rate', '\\1 (accepted)')",
               "textEditor": true
             },
             {
-              "target": "aliasSub(stats.counters.$namespace.$dispatcherName.queue.enqueueRejected.rate, '.*$namespace.(.*).queue.enqueueRejected.rate', '\\1 (rejected)')",
+              "target": "aliasSub(stats.counters.$namespace.$dispatcherName.work.rejected.rate, '.*$namespace.(.*).work.rejected.rate', '\\1 (rejected)')",
               "textEditor": true
             }
           ],
@@ -415,7 +415,7 @@
           "steppedLine": false,
           "targets": [
             {
-              "target": "aliasSub(stats.timers.$namespace.$dispatcherName.queue.avgProcessTime.mean, '.*$namespace.(.*).queue.*','\\1')",
+              "target": "aliasSub(stats.timers.$namespace.$dispatcherName.work.processTime.mean, '.*$namespace.(.*).queue.*','\\1')",
               "textEditor": true
             }
           ],
@@ -485,7 +485,7 @@
           "steppedLine": false,
           "targets": [
             {
-              "target": "aliasSub(stats.counters.$namespace.$dispatcherName.queue.circuitBreakerOpened.count,  '.*$namespace.(.*).queue.*', '\\1')",
+              "target": "aliasSub(stats.counters.$namespace.$dispatcherName.worker.circuitBreakerOpened.count,  '.*$namespace.(.*).queue.*', '\\1')",
               "textEditor": true
             }
           ],