aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/kamon/metric/ExecutorServiceMetricCollector.scala
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/scala/kamon/metric/ExecutorServiceMetricCollector.scala')
-rw-r--r--src/main/scala/kamon/metric/ExecutorServiceMetricCollector.scala8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/main/scala/kamon/metric/ExecutorServiceMetricCollector.scala b/src/main/scala/kamon/metric/ExecutorServiceMetricCollector.scala
index 78711267..54a13f39 100644
--- a/src/main/scala/kamon/metric/ExecutorServiceMetricCollector.scala
+++ b/src/main/scala/kamon/metric/ExecutorServiceMetricCollector.scala
@@ -34,7 +34,7 @@ trait ForkJoinPoolMetricCollector {
fullName + activeThreads -> forkJoinPoolGauge(_.getActiveThreadCount)
)
- allMetrics.foreach(kv => Metrics.registry.register(kv._1, kv._2))
+ allMetrics.foreach { case (name, metric) => Metrics.registry.register(name, metric) }
}
}
@@ -51,15 +51,15 @@ trait ThreadPoolExecutorMetricCollector {
fullName + activeThreads -> tpeGauge(_.getActiveCount)
)
- allMetrics.foreach(kv => Metrics.registry.register(kv._1, kv._2))
+ allMetrics.foreach { case (name, metric) => Metrics.registry.register(name, metric) }
}
}
object BasicExecutorMetricNames {
val queueSize = "queueSize"
- val poolSize = "poolSize"
- val activeThreads = "activeThreads"
+ val poolSize = "threads/poolSize"
+ val activeThreads = "threads/activeThreads"
}