aboutsummaryrefslogtreecommitdiff
path: root/kamon-playground
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
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')
-rw-r--r--kamon-playground/src/main/resources/application.conf4
-rw-r--r--kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala14
2 files changed, 16 insertions, 2 deletions
diff --git a/kamon-playground/src/main/resources/application.conf b/kamon-playground/src/main/resources/application.conf
index e9f73954..bac3c97e 100644
--- a/kamon-playground/src/main/resources/application.conf
+++ b/kamon-playground/src/main/resources/application.conf
@@ -1,7 +1,7 @@
akka {
loglevel = INFO
- extensions = ["kamon.newrelic.NewRelic"]
+ extensions = ["kamon.logreporter.LogReporter"]
actor {
debug {
@@ -25,7 +25,7 @@ kamon {
kamon {
metrics {
- tick-interval = 1 second
+ tick-interval = 10 second
filters = [
{
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" })
}
}