diff options
author | Ivan Topolnjak <ivantopo@gmail.com> | 2015-03-16 23:21:21 +0100 |
---|---|---|
committer | Ivan Topolnjak <ivantopo@gmail.com> | 2015-03-16 23:21:21 +0100 |
commit | 6a68dd54cf93592d7c3954895d255e4775b69f53 (patch) | |
tree | 2d3b1bf4319ee745673a97585f7e23a833ede76f /kamon-statsd/src/main/scala/kamon/statsd/SimpleMetricKeyGenerator.scala | |
parent | 01cea55d78de9994a230b7d612d4ee007ad59e73 (diff) | |
download | Kamon-6a68dd54cf93592d7c3954895d255e4775b69f53.tar.gz Kamon-6a68dd54cf93592d7c3954895d255e4775b69f53.tar.bz2 Kamon-6a68dd54cf93592d7c3954895d255e4775b69f53.zip |
+ statsd: fix akka and segments subscriptions and subscribe to simple metrics as well, fixes #166.
Diffstat (limited to 'kamon-statsd/src/main/scala/kamon/statsd/SimpleMetricKeyGenerator.scala')
-rw-r--r-- | kamon-statsd/src/main/scala/kamon/statsd/SimpleMetricKeyGenerator.scala | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/kamon-statsd/src/main/scala/kamon/statsd/SimpleMetricKeyGenerator.scala b/kamon-statsd/src/main/scala/kamon/statsd/SimpleMetricKeyGenerator.scala index 0fce855c..fc72e837 100644 --- a/kamon-statsd/src/main/scala/kamon/statsd/SimpleMetricKeyGenerator.scala +++ b/kamon-statsd/src/main/scala/kamon/statsd/SimpleMetricKeyGenerator.scala @@ -3,7 +3,7 @@ package kamon.statsd import java.lang.management.ManagementFactory import com.typesafe.config.Config -import kamon.metric.{ MetricKey, Entity } +import kamon.metric.{ SingleInstrumentEntityRecorder, MetricKey, Entity } trait MetricKeyGenerator { def generateKey(entity: Entity, metricKey: MetricKey): String @@ -28,7 +28,10 @@ class SimpleMetricKeyGenerator(config: Config) extends MetricKeyGenerator { def generateKey(entity: Entity, metricKey: MetricKey): String = { val normalizedGroupName = normalizer(entity.name) - s"${baseName}.${entity.category}.${normalizedGroupName}.${metricKey.name}" + if (SingleInstrumentEntityRecorder.AllCategories.contains(entity.category)) + s"${baseName}.${entity.category}.${normalizedGroupName}" + else + s"${baseName}.${entity.category}.${normalizedGroupName}.${metricKey.name}" } def hostName: String = ManagementFactory.getRuntimeMXBean.getName.split('@')(1) |