diff options
| author | Diego <diegolparra@gmail.com> | 2014-12-27 17:11:42 -0300 |
|---|---|---|
| committer | Diego <diegolparra@gmail.com> | 2014-12-27 17:11:42 -0300 |
| commit | 6c6186fa11f3b16e5ccdb4f233d08f32d5366958 (patch) | |
| tree | 6a9f77a14e5f7d4a09c366fd3971d61e32ea8fe7 | |
| parent | 81024fdedee84496212eb844092ec0b6e08da1a4 (diff) | |
| download | Kamon-6c6186fa11f3b16e5ccdb4f233d08f32d5366958.tar.gz Kamon-6c6186fa11f3b16e5ccdb4f233d08f32d5366958.tar.bz2 Kamon-6c6186fa11f3b16e5ccdb4f233d08f32d5366958.zip | |
+ datadog: includes Disk, NonHeap LoadAverage, Threads and ClassLoading metrics
| -rw-r--r-- | kamon-datadog/src/main/scala/kamon/datadog/Datadog.scala | 18 |
1 files 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 = { |