diff options
author | Ivan Topolnjak <ivantopo@gmail.com> | 2014-07-29 00:25:26 -0300 |
---|---|---|
committer | Ivan Topolnjak <ivantopo@gmail.com> | 2014-07-29 00:25:26 -0300 |
commit | e83babb5f88e91661bec2f1013fcb6b03612bea9 (patch) | |
tree | fc1f9fce81e9129128e5f1274dc05cda4fdfc62c /kamon-playground/src/main/scala | |
parent | ca65ad5b1bd5156ec487b435c9c015d6111963f0 (diff) | |
download | Kamon-e83babb5f88e91661bec2f1013fcb6b03612bea9.tar.gz Kamon-e83babb5f88e91661bec2f1013fcb6b03612bea9.tar.bz2 Kamon-e83babb5f88e91661bec2f1013fcb6b03612bea9.zip |
+ logreporter: new log reporter for trace, actor and user metrics, closes #57
The new kamon-log-reporter module subscribes itselfs for trace, actor
and user metrics and prints the values using ActorLogging in a pretty
ascii table format.
Diffstat (limited to 'kamon-playground/src/main/scala')
-rw-r--r-- | kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala | 14 |
1 files changed, 14 insertions, 0 deletions
diff --git a/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala b/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala index 84621927..301a9bbd 100644 --- a/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala +++ b/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala @@ -51,6 +51,19 @@ object SimpleRequestProcessor extends App with SimpleRoutingApp with RequestBuil implicit val timeout = Timeout(30 seconds) + val counter = Kamon(UserMetrics).registerCounter("requests") + Kamon(UserMetrics).registerCounter("requests-2") + Kamon(UserMetrics).registerCounter("requests-3") + + Kamon(UserMetrics).registerHistogram("histogram-1") + Kamon(UserMetrics).registerHistogram("histogram-2") + + Kamon(UserMetrics).registerMinMaxCounter("min-max-counter-1") + Kamon(UserMetrics).registerMinMaxCounter("min-max-counter-2") + Kamon(UserMetrics).registerMinMaxCounter("min-max-counter-3") + + //Kamon(UserMetrics).registerGauge("test-gauge")(() => 10L) + val pipeline = sendReceive val replier = system.actorOf(Props[Replier].withRouter(RoundRobinPool(nrOfInstances = 2)), "replier") val random = new Random() @@ -92,6 +105,7 @@ object SimpleRequestProcessor extends App with SimpleRoutingApp with RequestBuil path("future") { traceName("OK-Future") { dynamic { + counter.increment() complete(Future { "OK" }) } } |