From 4ef79b01d0b9d6cb4628886a8a2a29048d997b13 Mon Sep 17 00:00:00 2001 From: Ivan Topolnjak Date: Wed, 21 May 2014 09:09:34 -0300 Subject: + datadog: include identification tags and clean up all irrelevant code from StatsD --- kamon-datadog/src/main/scala/kamon/datadog/Datadog.scala | 11 +---------- 1 file changed, 1 insertion(+), 10 deletions(-) (limited to 'kamon-datadog/src/main/scala/kamon/datadog/Datadog.scala') diff --git a/kamon-datadog/src/main/scala/kamon/datadog/Datadog.scala b/kamon-datadog/src/main/scala/kamon/datadog/Datadog.scala index b492b9fd..c6981fd7 100644 --- a/kamon-datadog/src/main/scala/kamon/datadog/Datadog.scala +++ b/kamon-datadog/src/main/scala/kamon/datadog/Datadog.scala @@ -44,7 +44,6 @@ class DatadogExtension(system: ExtendedActorSystem) extends Kamon.Extension { val datadogHost = new InetSocketAddress(datadogConfig.getString("hostname"), datadogConfig.getInt("port")) val flushInterval = datadogConfig.getDuration("flush-interval", MILLISECONDS) - val maxPacketSizeInBytes = datadogConfig.getBytes("max-packet-size") val tickInterval = system.settings.config.getDuration("kamon.metrics.tick-interval", MILLISECONDS) val datadogMetricsListener = buildMetricsListener(tickInterval, flushInterval) @@ -64,7 +63,7 @@ class DatadogExtension(system: ExtendedActorSystem) extends Kamon.Extension { def buildMetricsListener(tickInterval: Long, flushInterval: Long): ActorRef = { assert(flushInterval >= tickInterval, "Datadog flush-interval needs to be equal or greater to the tick-interval") - val metricsTranslator = system.actorOf(DatadogMetricsSender.props(datadogHost, maxPacketSizeInBytes), "datadog-metrics-sender") + val metricsTranslator = system.actorOf(DatadogMetricsSender.props(datadogHost), "datadog-metrics-sender") if (flushInterval == tickInterval) { // No need to buffer the metrics, let's go straight to the metrics sender. metricsTranslator @@ -74,11 +73,3 @@ class DatadogExtension(system: ExtendedActorSystem) extends Kamon.Extension { } } -class SimpleMetricKeyGenerator(config: Config) extends Datadog.MetricKeyGenerator { - val application = config.getString("kamon.datadog.simple-metric-key-generator.application") - val localhostName = ManagementFactory.getRuntimeMXBean.getName.split('@')(1) - - def generateKey(groupIdentity: MetricGroupIdentity, metricIdentity: MetricIdentity): String = - s"${application}.${localhostName}.${groupIdentity.category.name}.${groupIdentity.name}.${metricIdentity.name}" -} - -- cgit v1.2.3