! all: improve the metric recorders infrastructure

1 files changed, 29 insertions, 0 deletions

diff --git a/kamon-system-metrics/src/main/scala/kamon/system/sigar/CpuMetrics.scala b/kamon-system-metrics/src/main/scala/kamon/system/sigar/CpuMetrics.scala
new file mode 100644
index 00000000..0a5f6494
--- /dev/null
+++ b/kamon-system-metrics/src/main/scala/kamon/system/sigar/CpuMetrics.scala
@@ -0,0 +1,29 @@
+package kamon.system.sigar
+
+import kamon.metric.GenericEntityRecorder
+import kamon.metric.instrument.InstrumentFactory
+import org.hyperic.sigar.Sigar
+
+class CpuMetrics(instrumentFactory: InstrumentFactory) extends GenericEntityRecorder(instrumentFactory) with SigarMetric {
+  val user = histogram("cpu-user")
+  val system = histogram("cpu-system")
+  val Wait = histogram("cpu-wait")
+  val idle = histogram("cpu-idle")
+  val stolen = histogram("cpu-stolen")
+
+  def update(sigar: Sigar): Unit = {
+    val cpuPerc = sigar.getCpuPerc
+
+    user.record((cpuPerc.getUser * 100L).toLong)
+    system.record((cpuPerc.getSys * 100L).toLong)
+    Wait.record((cpuPerc.getWait * 100L).toLong)
+    idle.record((cpuPerc.getIdle * 100L).toLong)
+    stolen.record((cpuPerc.getStolen * 100L).toLong)
+  }
+}
+
+object CpuMetrics extends SigarMetricRecorderCompanion("cpu") {
+
+  def apply(instrumentFactory: InstrumentFactory): CpuMetrics =
+    new CpuMetrics(instrumentFactory)
+}