From 6c6186fa11f3b16e5ccdb4f233d08f32d5366958 Mon Sep 17 00:00:00 2001 From: Diego Date: Sat, 27 Dec 2014 17:11:42 -0300 Subject: + datadog: includes Disk, NonHeap LoadAverage, Threads and ClassLoading metrics --- .../src/main/scala/kamon/datadog/Datadog.scala | 18 +++++++++++++++--- 1 file changed, 15 insertions(+), 3 deletions(-) diff --git a/kamon-datadog/src/main/scala/kamon/datadog/Datadog.scala b/kamon-datadog/src/main/scala/kamon/datadog/Datadog.scala index 20bf2561..5e5e08a1 100644 --- a/kamon-datadog/src/main/scala/kamon/datadog/Datadog.scala +++ b/kamon-datadog/src/main/scala/kamon/datadog/Datadog.scala @@ -88,9 +88,21 @@ class DatadogExtension(system: ExtendedActorSystem) extends Kamon.Extension { // Subscribe to SystemMetrics val includeSystemMetrics = datadogConfig.getBoolean("report-system-metrics") if (includeSystemMetrics) { - List(CPUMetrics, ProcessCPUMetrics, MemoryMetrics, NetworkMetrics, GCMetrics, HeapMetrics, ContextSwitchesMetrics) foreach { metric ⇒ - Kamon(Metrics)(system).subscribe(metric, "*", datadogMetricsListener, permanently = true) - } + //OS + Kamon(Metrics)(system).subscribe(CPUMetrics, "*", datadogMetricsListener, permanently = true) + Kamon(Metrics)(system).subscribe(ProcessCPUMetrics, "*", datadogMetricsListener, permanently = true) + Kamon(Metrics)(system).subscribe(MemoryMetrics, "*", datadogMetricsListener, permanently = true) + Kamon(Metrics)(system).subscribe(NetworkMetrics, "*", datadogMetricsListener, permanently = true) + Kamon(Metrics)(system).subscribe(DiskMetrics, "*", datadogMetricsListener, permanently = true) + Kamon(Metrics)(system).subscribe(ContextSwitchesMetrics, "*", datadogMetricsListener, permanently = true) + Kamon(Metrics)(system).subscribe(LoadAverageMetrics, "*", datadogMetricsListener, permanently = true) + + //JVM + Kamon(Metrics)(system).subscribe(HeapMetrics, "*", datadogMetricsListener, permanently = true) + Kamon(Metrics)(system).subscribe(NonHeapMetrics, "*", datadogMetricsListener, permanently = true) + Kamon(Metrics)(system).subscribe(ThreadMetrics, "*", datadogMetricsListener, permanently = true) + Kamon(Metrics)(system).subscribe(ClassLoadingMetrics, "*", datadogMetricsListener, permanently = true) + Kamon(Metrics)(system).subscribe(GCMetrics, "*", datadogMetricsListener, permanently = true) } def buildMetricsListener(tickInterval: Long, flushInterval: Long): ActorRef = { -- cgit v1.2.3