diff options
Diffstat (limited to 'kamon-playground/src')
-rw-r--r-- | kamon-playground/src/main/resources/application.conf | 5 | ||||
-rw-r--r-- | kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala | 22 |
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" }) } } |