diff options
author | Ivan Topolnjak <ivantopo@gmail.com> | 2015-02-15 01:47:32 +0100 |
---|---|---|
committer | Ivan Topolnjak <ivantopo@gmail.com> | 2015-02-15 01:47:32 +0100 |
commit | 81c52c27d2b4784d561ae63b884b6e8c9e03db58 (patch) | |
tree | 1414f438c83976d60e98d27041ec3c177094881e /kamon-datadog/src | |
parent | a313e1e94b1f8a660e24a47f7f76a28a97dad8ff (diff) | |
download | Kamon-81c52c27d2b4784d561ae63b884b6e8c9e03db58.tar.gz Kamon-81c52c27d2b4784d561ae63b884b6e8c9e03db58.tar.bz2 Kamon-81c52c27d2b4784d561ae63b884b6e8c9e03db58.zip |
= all: stop using config.getDuration in favor of config.getFiniteDuration.
Diffstat (limited to 'kamon-datadog/src')
-rw-r--r-- | kamon-datadog/src/main/scala/kamon/datadog/Datadog.scala | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/kamon-datadog/src/main/scala/kamon/datadog/Datadog.scala b/kamon-datadog/src/main/scala/kamon/datadog/Datadog.scala index 53ffd4e6..ab909055 100644 --- a/kamon-datadog/src/main/scala/kamon/datadog/Datadog.scala +++ b/kamon-datadog/src/main/scala/kamon/datadog/Datadog.scala @@ -17,7 +17,6 @@ package kamon.datadog import java.net.InetSocketAddress -import java.util.concurrent.TimeUnit.MILLISECONDS import akka.actor._ import akka.event.Logging @@ -41,9 +40,9 @@ class DatadogExtension(system: ExtendedActorSystem) extends Kamon.Extension { private val datadogConfig = system.settings.config.getConfig("kamon.datadog") val datadogHost = new InetSocketAddress(datadogConfig.getString("hostname"), datadogConfig.getInt("port")) - val flushInterval = datadogConfig.getDuration("flush-interval", MILLISECONDS) + val flushInterval = datadogConfig.getFiniteDuration("flush-interval") val maxPacketSizeInBytes = datadogConfig.getBytes("max-packet-size") - val tickInterval = system.settings.config.getDuration("kamon.metric.tick-interval", MILLISECONDS) + val tickInterval = Kamon.metrics.settings.tickInterval val datadogMetricsListener = buildMetricsListener(tickInterval, flushInterval) @@ -54,7 +53,7 @@ class DatadogExtension(system: ExtendedActorSystem) extends Kamon.Extension { } } - def buildMetricsListener(tickInterval: Long, flushInterval: Long): ActorRef = { + def buildMetricsListener(tickInterval: FiniteDuration, flushInterval: FiniteDuration): ActorRef = { assert(flushInterval >= tickInterval, "Datadog flush-interval needs to be equal or greater to the tick-interval") val metricsSender = system.actorOf(DatadogMetricsSender.props(datadogHost, maxPacketSizeInBytes), "datadog-metrics-sender") @@ -62,7 +61,7 @@ class DatadogExtension(system: ExtendedActorSystem) extends Kamon.Extension { // No need to buffer the metrics, let's go straight to the metrics sender. metricsSender } else { - system.actorOf(TickMetricSnapshotBuffer.props(flushInterval.toInt.millis, metricsSender), "datadog-metrics-buffer") + system.actorOf(TickMetricSnapshotBuffer.props(flushInterval, metricsSender), "datadog-metrics-buffer") } } } |