Add ability to set custom tags for statsd metrics (close #340)

core/src/main/scala/com.snowplowanalytics.snowplow.collectors.scalastream/Collector.scala

@@ -136,7 +136,9 @@ trait Collector {
     )
 
     lazy val metricRegistry: Option[HttpMetricsRegistry] = collectorConf.monitoring.metrics.statsd match {
-      case StatsdConfig(true, hostname, port, period, prefix) =>
+      case StatsdConfig(true, hostname, port, period, prefix, tags) =>
+        val constantTags = tags.map { case (k: String, v: String)  => s"${k}:${v}" }
+
         Some(
           DatadogRegistry(
             client = new NonBlockingStatsDClientBuilder()
@@ -145,6 +147,7 @@ trait Collector {
               .enableAggregation(true)
               .aggregationFlushInterval(period.toMillis.toInt)
               .enableTelemetry(false)
+              .constantTags(constantTags.toArray: _*)
               .build(),
             DatadogSettings
               .default

core/src/main/scala/com.snowplowanalytics.snowplow.collectors.scalastream/model.scala

@@ -174,8 +174,9 @@ package model {
     enabled: Boolean,
     hostname: String,
     port: Int,
-    period: FiniteDuration = 1.minute,
-    prefix: String         = "snowplow.collector"
+    period: FiniteDuration    = 1.minute,
+    prefix: String            = "snowplow.collector",
+    tags: Map[String, String] = Map("app" -> "collector")
   )
   final case class MetricsConfig(statsd: StatsdConfig)
   final case class MonitoringConfig(metrics: MetricsConfig)

examples/config.kafka.extended.hocon

@@ -242,6 +242,11 @@ collector {
       period = "10 seconds"
       # Optional, override the default metric prefix
       # "prefix": "snowplow.collector"
+
+      # Any key-value pairs to be tagged on every StatsD metric
+      "tags": {
+        "app": collector
+      }
   }
 
   # Configures how long the colletor should pause after receiving a sigterm before starting the graceful shutdown.

examples/config.kinesis.extended.hocon

@@ -281,6 +281,11 @@ collector {
       period = "10 seconds"
       # Optional, override the default metric prefix
       # "prefix": "snowplow.collector"
+
+      # Any key-value pairs to be tagged on every StatsD metric
+      "tags": {
+        "app": collector
+      }
    }
 
   # Configures how long the colletor should pause after receiving a sigterm before starting the graceful shutdown.

examples/config.nsq.extended.hocon

@@ -220,6 +220,11 @@ collector {
       period = "10 seconds"
       # Optional, override the default metric prefix
       # "prefix": "snowplow.collector"
+
+      # Any key-value pairs to be tagged on every StatsD metric
+      "tags": {
+        "app": collector
+      }
    }
 
   # Configures how long the colletor should pause after receiving a sigterm before starting the graceful shutdown.

examples/config.pubsub.extended.hocon

@@ -251,6 +251,11 @@ collector {
       period = "10 seconds"
       # Optional, override the default metric prefix
       # "prefix": "snowplow.collector"
+
+      # Any key-value pairs to be tagged on every StatsD metric
+      "tags": {
+        "app": collector
+      }
    }
 
   # Configures how long the colletor should pause after receiving a sigterm before starting the graceful shutdown.

examples/config.rabbitmq.extended.hocon

@@ -238,6 +238,11 @@ collector {
       period = "10 seconds"
       # Optional, override the default metric prefix
       # "prefix": "snowplow.collector"
+
+      # Any key-value pairs to be tagged on every StatsD metric
+      "tags": {
+        "app": collector
+      }
    }
 
   # Configures how long the colletor should pause after receiving a sigterm before starting the graceful shutdown.

examples/config.sqs.extended.hocon

@@ -263,6 +263,11 @@ collector {
       period = "10 seconds"
       # Optional, override the default metric prefix
       # "prefix": "snowplow.collector"
+
+      # Any key-value pairs to be tagged on every StatsD metric
+      "tags": {
+        "app": collector
+      }
   }
 
   # Configures how long the colletor should pause after receiving a sigterm before starting the graceful shutdown.

examples/config.stdout.extended.hocon

@@ -227,6 +227,11 @@ collector {
       period = "10 seconds"
       # Optional, override the default metric prefix
       # "prefix": "snowplow.collector"
+
+      # Any key-value pairs to be tagged on every StatsD metric
+      "tags": {
+        "app": collector
+      }
    }
 
   # Configures how long the colletor should pause after receiving a sigterm before starting the graceful shutdown.