diff options
author | Ivan Topolnak <itopolnak@despegar.com> | 2014-02-04 15:58:30 -0300 |
---|---|---|
committer | Ivan Topolnak <itopolnak@despegar.com> | 2014-02-04 15:58:30 -0300 |
commit | 7307e1cc97e0363d1fb4cc116fc69a5272ca3730 (patch) | |
tree | e83335d877d895b4a45a2a5b264719adf2435570 /kamon-playground/src/main/scala | |
parent | 5d296a16270b1ec66d206ef1195208ea864f49c1 (diff) | |
download | Kamon-7307e1cc97e0363d1fb4cc116fc69a5272ca3730.tar.gz Kamon-7307e1cc97e0363d1fb4cc116fc69a5272ca3730.tar.bz2 Kamon-7307e1cc97e0363d1fb4cc116fc69a5272ca3730.zip |
metrics buffer for easier periodic reporting
Diffstat (limited to 'kamon-playground/src/main/scala')
-rw-r--r-- | kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala b/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala index cd497ca5..fb3d05d2 100644 --- a/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala +++ b/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala @@ -25,7 +25,7 @@ import scala.util.Random import akka.routing.RoundRobinRouter import kamon.trace.TraceRecorder import kamon.Kamon -import kamon.metrics.{ ActorMetrics, TraceMetrics, Metrics } +import kamon.metrics.{TickMetricSnapshotBuffer, ActorMetrics, TraceMetrics, Metrics} import spray.http.{ StatusCodes, Uri } import kamon.metrics.Subscriptions.TickMetricSnapshot import kamon.newrelic.WebTransactionMetrics @@ -44,7 +44,9 @@ object SimpleRequestProcessor extends App with SimpleRoutingApp with RequestBuil def receive: Actor.Receive = { case any ⇒ sender ! any } }), "com") - Kamon(Metrics).subscribe(TraceMetrics, "*", printer, permanently = true) + val buffer = system.actorOf(TickMetricSnapshotBuffer.props(10 seconds, printer)) + + Kamon(Metrics).subscribe(TraceMetrics, "*", buffer, permanently = true) //Kamon(Metrics).subscribe(ActorMetrics, "*", printer, permanently = true) implicit val timeout = Timeout(30 seconds) |