diff options
author | Diego <diegolparra@gmail.com> | 2016-12-04 15:37:51 -0300 |
---|---|---|
committer | Diego <diegolparra@gmail.com> | 2016-12-04 15:37:51 -0300 |
commit | 56039ef037d42cb817d0bc6d5a5891bc87e633c3 (patch) | |
tree | 711d36b49d69f7321ea75172d9d4969e318d7afe /kamon-core/src/main/scala/kamon/metric/MetricScaleDecorator.scala | |
parent | e02d137ab960676cb89ff597bc33915f8b83a4d2 (diff) | |
download | Kamon-56039ef037d42cb817d0bc6d5a5891bc87e633c3.tar.gz Kamon-56039ef037d42cb817d0bc6d5a5891bc87e633c3.tar.bz2 Kamon-56039ef037d42cb817d0bc6d5a5891bc87e633c3.zip |
wip
Diffstat (limited to 'kamon-core/src/main/scala/kamon/metric/MetricScaleDecorator.scala')
-rw-r--r-- | kamon-core/src/main/scala/kamon/metric/MetricScaleDecorator.scala | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/kamon-core/src/main/scala/kamon/metric/MetricScaleDecorator.scala b/kamon-core/src/main/scala/kamon/metric/MetricScaleDecorator.scala index e096429d..06de65ef 100644 --- a/kamon-core/src/main/scala/kamon/metric/MetricScaleDecorator.scala +++ b/kamon-core/src/main/scala/kamon/metric/MetricScaleDecorator.scala @@ -16,7 +16,7 @@ package kamon.metric -import akka.actor.{ Actor, ActorRef, Props } +import akka.actor.{Actor, ActorRef, Props} import kamon.metric.SubscriptionsDispatcher.TickMetricSnapshot import kamon.metric.instrument._ @@ -28,8 +28,10 @@ import kamon.metric.instrument._ * @param receiver Receiver of scaled metrics snapshot, usually a backend sender */ class MetricScaleDecorator(timeUnits: Option[Time], memoryUnits: Option[Memory], receiver: ActorRef) extends Actor { - require(timeUnits.isDefined || memoryUnits.isDefined, - "Use MetricScaleDecorator only when any of units is defined") + require( + timeUnits.isDefined || memoryUnits.isDefined, + "Use MetricScaleDecorator only when any of units is defined" + ) override def receive: Receive = { case tick: TickMetricSnapshot ⇒ @@ -41,7 +43,7 @@ class MetricScaleDecorator(timeUnits: Option[Time], memoryUnits: Option[Memory], case (memory: Memory, _, Some(to)) ⇒ metricSnapshot.scale(memory, to) case _ ⇒ metricSnapshot } - metricKey -> scaledSnapshot + metricKey → scaledSnapshot }) }) receiver forward scaled |