diff options
Diffstat (limited to 'kamon-statsd/src/main/scala/kamon/statsd/StatsdMetricTranslator.scala')
-rw-r--r-- | kamon-statsd/src/main/scala/kamon/statsd/StatsdMetricTranslator.scala | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/kamon-statsd/src/main/scala/kamon/statsd/StatsdMetricTranslator.scala b/kamon-statsd/src/main/scala/kamon/statsd/StatsdMetricTranslator.scala index 2cf672b8..2ef41c6d 100644 --- a/kamon-statsd/src/main/scala/kamon/statsd/StatsdMetricTranslator.scala +++ b/kamon-statsd/src/main/scala/kamon/statsd/StatsdMetricTranslator.scala @@ -29,7 +29,7 @@ class StatsDMetricTranslator extends Actor { def receive = { case TickMetricSnapshot(from, to, metrics) ⇒ val translatedMetrics = metrics.collect { - case (am @ ActorMetrics(_), snapshot: ActorMetricSnapshot) => transformActorMetric(am, snapshot) + case (am @ ActorMetrics(_), snapshot: ActorMetricSnapshot) ⇒ transformActorMetric(am, snapshot) } metricSender ! StatsD.MetricBatch(translatedMetrics.flatten) @@ -42,9 +42,9 @@ class StatsDMetricTranslator extends Actor { roll(timeInMailboxKey, snapshot.timeInMailbox, StatsD.Timing) ++ roll(processingTimeKey, snapshot.processingTime, StatsD.Timing) } - def roll(key: String, snapshot: MetricSnapshotLike, metricBuilder: (String, Double, Double) => StatsD.Metric): Vector[StatsD.Metric] = { + def roll(key: String, snapshot: MetricSnapshotLike, metricBuilder: (String, Double, Double) ⇒ StatsD.Metric): Vector[StatsD.Metric] = { val builder = Vector.newBuilder[StatsD.Metric] - for(measurement <- snapshot.measurements) { + for (measurement ← snapshot.measurements) { val samplingRate = 1D / measurement.count val scaledValue = Scale.convert(snapshot.scale, Scale.Milli, measurement.value) builder += metricBuilder.apply(key, scaledValue, samplingRate) @@ -53,7 +53,6 @@ class StatsDMetricTranslator extends Actor { builder.result() } - } object StatsDMetricTranslator { |