+ statsd: add the include-hostname setting to the default key generator

 * This commit adds 'include-hostname' the default key generator setting
   in statsd. When set to false, the generated keys wont include host
   information. They will have the following scheme:

   application.entity.entity-name.metric-name

1 files changed, 9 insertions, 5 deletions

diff --git a/kamon-statsd/src/main/scala/kamon/statsd/StatsD.scala b/kamon-statsd/src/main/scala/kamon/statsd/StatsD.scala
index ff273d9f..76ef8d5f 100644
--- a/kamon-statsd/src/main/scala/kamon/statsd/StatsD.scala
+++ b/kamon-statsd/src/main/scala/kamon/statsd/StatsD.scala
@@ -105,6 +105,8 @@ class StatsDExtension(system: ExtendedActorSystem) extends Kamon.Extension {
 
 class SimpleMetricKeyGenerator(config: Config) extends StatsD.MetricKeyGenerator {
   val application = config.getString("kamon.statsd.simple-metric-key-generator.application")
+  val includeHostnameInMetrics =
+    config.getBoolean("kamon.statsd.simple-metric-key-generator.include-hostname")
   val _localhostName = ManagementFactory.getRuntimeMXBean.getName.split('@')(1)
   val _normalizedLocalhostName = _localhostName.replace('.', '_')
 
@@ -112,13 +114,16 @@ class SimpleMetricKeyGenerator(config: Config) extends StatsD.MetricKeyGenerator
 
   def normalizedLocalhostName: String = _normalizedLocalhostName
 
+  val baseName: String =
+    if (includeHostnameInMetrics) s"${application}.${normalizedLocalhostName}"
+    else application
+
   def generateKey(groupIdentity: MetricGroupIdentity, metricIdentity: MetricIdentity): String = {
     val normalizedGroupName = groupIdentity.name.replace(": ", "-").replace(" ", "_").replace("/", "_")
+    val key = s"${baseName}.${groupIdentity.category.name}.${normalizedGroupName}"
 
-    if (isUserMetric(groupIdentity))
-      s"${application}.${normalizedLocalhostName}.${groupIdentity.category.name}.${normalizedGroupName}"
-    else
-      s"${application}.${normalizedLocalhostName}.${groupIdentity.category.name}.${normalizedGroupName}.${metricIdentity.name}"
+    if (isUserMetric(groupIdentity)) key
+    else s"${key}.${metricIdentity.name}"
   }
 
   def isUserMetric(groupIdentity: MetricGroupIdentity): Boolean = groupIdentity match {
@@ -126,4 +131,3 @@ class SimpleMetricKeyGenerator(config: Config) extends StatsD.MetricKeyGenerator
     case everythingElse                  ⇒ false
   }
 }
-