! all: improve the metric recorders infrastructure

1 files changed, 36 insertions, 0 deletions

diff --git a/kamon-system-metrics/src/main/scala/kamon/system/sigar/MemoryMetrics.scala b/kamon-system-metrics/src/main/scala/kamon/system/sigar/MemoryMetrics.scala
new file mode 100644
index 00000000..ab7fcd88
--- /dev/null
+++ b/kamon-system-metrics/src/main/scala/kamon/system/sigar/MemoryMetrics.scala
@@ -0,0 +1,36 @@
+package kamon.system.sigar
+
+import kamon.metric.GenericEntityRecorder
+import kamon.metric.instrument.{ Memory, InstrumentFactory }
+import org.hyperic.sigar.Sigar
+
+/**
+ *  System memory usage metrics, as reported by Sigar:
+ *    - used: Total used system memory.
+ *    - free: Total free system memory (e.g. Linux plus cached).
+ *    - swap-used: Total used system swap..
+ *    - swap-free: Total free system swap.
+ */
+class MemoryMetrics(instrumentFactory: InstrumentFactory) extends GenericEntityRecorder(instrumentFactory) with SigarMetric {
+  val used = histogram("memory-used", Memory.Bytes)
+  val free = histogram("memory-free", Memory.Bytes)
+  val swapUsed = histogram("swap-used", Memory.Bytes)
+  val swapFree = histogram("swap-free", Memory.Bytes)
+
+  def update(sigar: Sigar): Unit = {
+    val mem = sigar.getMem
+    val swap = sigar.getSwap
+
+    used.record(mem.getUsed)
+    free.record(mem.getFree)
+    swapUsed.record(swap.getUsed)
+    swapFree.record(swap.getFree)
+  }
+}
+
+object MemoryMetrics extends SigarMetricRecorderCompanion("memory") {
+
+  def apply(instrumentFactory: InstrumentFactory): MemoryMetrics =
+    new MemoryMetrics(instrumentFactory)
+}
+