aboutsummaryrefslogtreecommitdiff
path: root/kamon-core/src/main/scala/kamon/metrics/Subscriptions.scala
diff options
context:
space:
mode:
Diffstat (limited to 'kamon-core/src/main/scala/kamon/metrics/Subscriptions.scala')
-rw-r--r--kamon-core/src/main/scala/kamon/metrics/Subscriptions.scala20
1 files changed, 9 insertions, 11 deletions
diff --git a/kamon-core/src/main/scala/kamon/metrics/Subscriptions.scala b/kamon-core/src/main/scala/kamon/metrics/Subscriptions.scala
index 2111563b..4b022377 100644
--- a/kamon-core/src/main/scala/kamon/metrics/Subscriptions.scala
+++ b/kamon-core/src/main/scala/kamon/metrics/Subscriptions.scala
@@ -16,10 +16,10 @@
package kamon.metrics
-import akka.actor.{Props, ActorRef, Actor}
+import akka.actor.{ Props, ActorRef, Actor }
import kamon.metrics.Subscriptions.{ MetricGroupFilter, FlushMetrics, TickMetricSnapshot, Subscribe }
import kamon.util.GlobPathFilter
-import scala.concurrent.duration.{FiniteDuration, Duration}
+import scala.concurrent.duration.{ FiniteDuration, Duration }
import java.util.concurrent.TimeUnit
import kamon.Kamon
import kamon.metrics.TickMetricSnapshotBuffer.FlushBuffer
@@ -88,38 +88,36 @@ object Subscriptions {
}
}
-
class TickMetricSnapshotBuffer(flushInterval: FiniteDuration, receiver: ActorRef) extends Actor {
val flushSchedule = context.system.scheduler.schedule(flushInterval, flushInterval, self, FlushBuffer)(context.dispatcher)
def receive = empty
def empty: Actor.Receive = {
- case tick : TickMetricSnapshot => context become(buffering(tick))
- case FlushBuffer => // Nothing to flush.
+ case tick: TickMetricSnapshot ⇒ context become (buffering(tick))
+ case FlushBuffer ⇒ // Nothing to flush.
}
def buffering(buffered: TickMetricSnapshot): Actor.Receive = {
- case TickMetricSnapshot(_, to, tickMetrics) =>
+ case TickMetricSnapshot(_, to, tickMetrics) ⇒
val combinedMetrics = combineMaps(buffered.metrics, tickMetrics)(mergeMetricGroup)
val combinedSnapshot = TickMetricSnapshot(buffered.from, to, combinedMetrics)
- context become(buffering(combinedSnapshot))
+ context become (buffering(combinedSnapshot))
- case FlushBuffer =>
+ case FlushBuffer ⇒
receiver ! buffered
- context become(empty)
+ context become (empty)
}
-
override def postStop(): Unit = {
flushSchedule.cancel()
super.postStop()
}
def mergeMetricGroup(left: MetricGroupSnapshot, right: MetricGroupSnapshot) = new MetricGroupSnapshot {
- val metrics = combineMaps(left.metrics, right.metrics)((l, r) => l.merge(r))
+ val metrics = combineMaps(left.metrics, right.metrics)((l, r) ⇒ l.merge(r))
}
}