diff options
Diffstat (limited to 'kamon-newrelic/src/main/scala/kamon/newrelic/WebTransactionMetrics.scala')
-rw-r--r-- | kamon-newrelic/src/main/scala/kamon/newrelic/WebTransactionMetrics.scala | 17 |
1 files changed, 8 insertions, 9 deletions
diff --git a/kamon-newrelic/src/main/scala/kamon/newrelic/WebTransactionMetrics.scala b/kamon-newrelic/src/main/scala/kamon/newrelic/WebTransactionMetrics.scala index e10e9271..7fe5793c 100644 --- a/kamon-newrelic/src/main/scala/kamon/newrelic/WebTransactionMetrics.scala +++ b/kamon-newrelic/src/main/scala/kamon/newrelic/WebTransactionMetrics.scala @@ -17,18 +17,17 @@ package kamon.newrelic import kamon.metrics.{ TraceMetrics, MetricGroupSnapshot, MetricGroupIdentity } +import kamon.metrics.TraceMetrics.ElapsedTime -object WebTransactionMetrics { - def collectWebTransactionMetrics(metrics: Map[MetricGroupIdentity, MetricGroupSnapshot]): List[Metric] = { - metrics.collect { +trait WebTransactionMetrics { + def collectWebTransactionMetrics(metrics: Map[MetricGroupIdentity, MetricGroupSnapshot]): List[NewRelic.Metric] = { + val webTransactionMetrics = metrics.collect { case (TraceMetrics(name), groupSnapshot) ⇒ - - - groupSnapshot.metrics foreach { - case (metricIdentity, snapshot) => println(s"[$name] - ${toNewRelicMetric(name, None, snapshot)}") - } + groupSnapshot.metrics collect { + case (ElapsedTime, snapshot) => toNewRelicMetric("HttpDispatcher", None, snapshot) + } } - Nil + webTransactionMetrics.flatten.toList } } |