From e201e684fdc7fcf7aef090757e2690c538e75e07 Mon Sep 17 00:00:00 2001 From: Ivan Topolnak Date: Wed, 9 Apr 2014 17:30:17 -0300 Subject: + statsd: report trace metrics to StatsD --- .../src/main/scala/kamon/statsd/StatsDMetricsSender.scala | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) (limited to 'kamon-statsd/src/main/scala/kamon/statsd/StatsDMetricsSender.scala') diff --git a/kamon-statsd/src/main/scala/kamon/statsd/StatsDMetricsSender.scala b/kamon-statsd/src/main/scala/kamon/statsd/StatsDMetricsSender.scala index 0520b621..cff970b4 100644 --- a/kamon-statsd/src/main/scala/kamon/statsd/StatsDMetricsSender.scala +++ b/kamon-statsd/src/main/scala/kamon/statsd/StatsDMetricsSender.scala @@ -26,11 +26,9 @@ import kamon.metrics.MetricSnapshot.Measurement import kamon.metrics.InstrumentTypes.{ Counter, Gauge, Histogram, InstrumentType } import java.text.DecimalFormat -class StatsDMetricsSender extends Actor with UdpExtensionProvider { +class StatsDMetricsSender(remote: InetSocketAddress, maxPacketSize: Int) extends Actor with UdpExtensionProvider { import context.system - val statsDExtension = Kamon(StatsD) - val remote = new InetSocketAddress(statsDExtension.hostname, statsDExtension.port) val metricKeyGenerator = new SimpleMetricKeyGenerator(context.system.settings.config) val samplingRateFormat = new DecimalFormat() samplingRateFormat.setMaximumFractionDigits(128) // Absurdly high, let the other end loss precision if it needs to. @@ -47,7 +45,7 @@ class StatsDMetricsSender extends Actor with UdpExtensionProvider { } def writeMetricsToRemote(tick: TickMetricSnapshot, udpSender: ActorRef): Unit = { - val dataBuilder = new MetricDataPacketBuilder(statsDExtension.maxPacketSize, udpSender, remote) + val dataBuilder = new MetricDataPacketBuilder(maxPacketSize, udpSender, remote) for ( (groupIdentity, groupSnapshot) ← tick.metrics; @@ -78,7 +76,7 @@ class StatsDMetricsSender extends Actor with UdpExtensionProvider { } object StatsDMetricsSender { - def props: Props = Props[StatsDMetricsSender] + def props(remote: InetSocketAddress, maxPacketSize: Int): Props = Props(new StatsDMetricsSender(remote, maxPacketSize)) } trait UdpExtensionProvider { -- cgit v1.2.3