diff options
author | Ivan Topolnak <itopolnak@despegar.com> | 2014-04-09 17:30:17 -0300 |
---|---|---|
committer | Ivan Topolnak <itopolnak@despegar.com> | 2014-04-09 17:30:17 -0300 |
commit | e201e684fdc7fcf7aef090757e2690c538e75e07 (patch) | |
tree | 26c25821754850979a39d4567935e32eace7807e /kamon-statsd/src/main/scala/kamon/statsd/StatsDMetricsSender.scala | |
parent | 87745904e9826ea9078ef7202d56d1773b2c698a (diff) | |
download | Kamon-e201e684fdc7fcf7aef090757e2690c538e75e07.tar.gz Kamon-e201e684fdc7fcf7aef090757e2690c538e75e07.tar.bz2 Kamon-e201e684fdc7fcf7aef090757e2690c538e75e07.zip |
+ statsd: report trace metrics to StatsD
Diffstat (limited to 'kamon-statsd/src/main/scala/kamon/statsd/StatsDMetricsSender.scala')
-rw-r--r-- | kamon-statsd/src/main/scala/kamon/statsd/StatsDMetricsSender.scala | 8 |
1 files changed, 3 insertions, 5 deletions
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 { |