aboutsummaryrefslogtreecommitdiff
path: root/kamon-statsd/src/main/scala/kamon/statsd/StatsdMetricTranslator.scala
diff options
context:
space:
mode:
Diffstat (limited to 'kamon-statsd/src/main/scala/kamon/statsd/StatsdMetricTranslator.scala')
-rw-r--r--kamon-statsd/src/main/scala/kamon/statsd/StatsdMetricTranslator.scala7
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 {