aboutsummaryrefslogtreecommitdiff
path: root/kamon-playground/src/main/scala
diff options
context:
space:
mode:
authorIvan Topolnjak <ivantopo@gmail.com>2014-07-29 00:25:26 -0300
committerIvan Topolnjak <ivantopo@gmail.com>2014-07-29 00:25:26 -0300
commite83babb5f88e91661bec2f1013fcb6b03612bea9 (patch)
treefc1f9fce81e9129128e5f1274dc05cda4fdfc62c /kamon-playground/src/main/scala
parentca65ad5b1bd5156ec487b435c9c015d6111963f0 (diff)
downloadKamon-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.scala14
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" })
}
}