1 files changed, 39 insertions, 0 deletions
diff --git a/kamon-system-metrics/src/main/scala/kamon/system/sigar/ProcessCpuMetrics.scala b/kamon-system-metrics/src/main/scala/kamon/system/sigar/ProcessCpuMetrics.scala
new file mode 100644
index 00000000..0ca5c1c8
--- /dev/null
+++ b/kamon-system-metrics/src/main/scala/kamon/system/sigar/ProcessCpuMetrics.scala
@@ -0,0 +1,39 @@
+package kamon.system.sigar
+
+import kamon.metric.GenericEntityRecorder
+import kamon.metric.instrument.InstrumentFactory
+import org.hyperic.sigar.{ ProcCpu, Sigar }
+
+class ProcessCpuMetrics(instrumentFactory: InstrumentFactory) extends GenericEntityRecorder(instrumentFactory) with SigarMetric {
+  val processUserCpu = histogram("process-user-cpu")
+  val processSystemCpu = histogram("process-system-cpu")
+  val processTotalCpu = histogram("process-cpu")
+
+  var lastProcCpu: Option[ProcCpu] = None
+
+  def update(sigar: Sigar): Unit = {
+    val pid = sigar.getPid
+    val procCpu = sigar.getProcCpu(pid)
+
+    lastProcCpu.map { last ⇒
+      val timeDiff = procCpu.getLastTime - last.getLastTime
+      if (timeDiff > 0) {
+        val userPercent = (((procCpu.getUser - last.getUser) / timeDiff.toDouble) * 100).toLong
+        val systemPercent = (((procCpu.getSys - last.getSys) / timeDiff.toDouble) * 100).toLong
+
+        processUserCpu.record(userPercent)
+        processSystemCpu.record(systemPercent)
+        processTotalCpu.record(userPercent + systemPercent)
+      }
+    }
+
+    lastProcCpu = Some(procCpu)
+
+  }
+}
+
+object ProcessCpuMetrics extends SigarMetricRecorderCompanion("process-cpu") {
+
+  def apply(instrumentFactory: InstrumentFactory): ProcessCpuMetrics =
+    new ProcessCpuMetrics(instrumentFactory)
+}