Merge branch 'wip/improve-metric-recorders-infrastructure'

Conflicts:
	kamon-system-metrics/src/main/scala/kamon/system/SystemMetricsCollector.scala

1 files changed, 26 insertions, 0 deletions

diff --git a/kamon-core/src/main/scala/kamon/util/ConfigTools.scala b/kamon-core/src/main/scala/kamon/util/ConfigTools.scala
new file mode 100644
index 00000000..9810428e
--- /dev/null
+++ b/kamon-core/src/main/scala/kamon/util/ConfigTools.scala
@@ -0,0 +1,26 @@
+package kamon.util
+
+import java.util.concurrent.TimeUnit
+
+import com.typesafe.config.Config
+
+import scala.concurrent.duration.FiniteDuration
+
+object ConfigTools {
+  implicit class Syntax(val config: Config) extends AnyVal {
+    // We are using the deprecated .getNanoseconds option to keep Kamon source code compatible with
+    // versions of Akka using older typesafe-config versions.
+
+    def getFiniteDuration(path: String): FiniteDuration =
+      FiniteDuration(config.getNanoseconds(path), TimeUnit.NANOSECONDS)
+
+    def firstLevelKeys: Set[String] = {
+      import scala.collection.JavaConverters._
+
+      config.entrySet().asScala.map {
+        case entry ⇒ entry.getKey.takeWhile(_ != '.')
+      } toSet
+    }
+  }
+
+}