aboutsummaryrefslogtreecommitdiff
path: root/kamon-playground/src
diff options
context:
space:
mode:
Diffstat (limited to 'kamon-playground/src')
-rw-r--r--kamon-playground/src/main/resources/application.conf5
-rw-r--r--kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala22
2 files changed, 19 insertions, 8 deletions
diff --git a/kamon-playground/src/main/resources/application.conf b/kamon-playground/src/main/resources/application.conf
index 3d57141a..bac3c97e 100644
--- a/kamon-playground/src/main/resources/application.conf
+++ b/kamon-playground/src/main/resources/application.conf
@@ -1,6 +1,7 @@
akka {
loglevel = INFO
+ extensions = ["kamon.logreporter.LogReporter"]
actor {
debug {
@@ -18,13 +19,13 @@ spray.can {
kamon {
newrelic {
app-name = "SimpleRequestProcessor"
- license-key = 2e24765acb032cb9e7207013b5ba3e2ab7d2d75c
+ license-key = e7d350b14228f3d28f35bc3140df2c3e565ea5d5
}
}
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 05859ee5..e60a4b2a 100644
--- a/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala
+++ b/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala
@@ -26,10 +26,9 @@ import scala.util.Random
import akka.routing.RoundRobinRouter
import kamon.trace.TraceRecorder
import kamon.Kamon
-import kamon.metrics._
+import kamon.metric._
import spray.http.{ StatusCodes, Uri }
-import kamon.metrics.Subscriptions.TickMetricSnapshot
-import kamon.newrelic.WebTransactionMetrics
+import kamon.metric.Subscriptions.TickMetricSnapshot
object SimpleRequestProcessor extends App with SimpleRoutingApp with RequestBuilding with KamonTraceDirectives {
import scala.concurrent.duration._
@@ -52,12 +51,23 @@ 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(RoundRobinRouter(nrOfInstances = 2)), "replier")
val random = new Random()
- val requestCountRecorder = Kamon(Metrics).register(CustomMetric("GetCount"), CustomMetric.histogram(10, 3, Scale.Unit))
-
startServer(interface = "localhost", port = 9090) {
get {
path("test") {
@@ -88,7 +98,6 @@ object SimpleRequestProcessor extends App with SimpleRoutingApp with RequestBuil
path("ok") {
traceName("OK") {
complete {
- requestCountRecorder.map(_.record(1))
"ok"
}
}
@@ -96,6 +105,7 @@ object SimpleRequestProcessor extends App with SimpleRoutingApp with RequestBuil
path("future") {
traceName("OK-Future") {
dynamic {
+ counter.increment()
complete(Future { "OK" })
}
}