From 13f87299a11f14333268670a3d677358ebf2d178 Mon Sep 17 00:00:00 2001 From: Ivan Topolnjak Date: Fri, 6 Apr 2018 01:47:40 +0200 Subject: add the EnvironmentTagBuilder utility class --- .../scala/kamon/util/EnvironmentTagBuilder.scala | 43 ++++++++++++++++++++++ 1 file changed, 43 insertions(+) create mode 100644 kamon-core/src/main/scala/kamon/util/EnvironmentTagBuilder.scala (limited to 'kamon-core') diff --git a/kamon-core/src/main/scala/kamon/util/EnvironmentTagBuilder.scala b/kamon-core/src/main/scala/kamon/util/EnvironmentTagBuilder.scala new file mode 100644 index 00000000..09e643e9 --- /dev/null +++ b/kamon-core/src/main/scala/kamon/util/EnvironmentTagBuilder.scala @@ -0,0 +1,43 @@ +package kamon.util + +import com.typesafe.config.Config +import kamon.{Environment, Kamon} + +import scala.collection.JavaConverters._ + + +/** + * Utility class to create a Map[String, String] encoding all the Environment information based on the provided + * Config. The Config instance is expected to have the following members: + * + * - service: Boolean. If true a service tag is included. + * - host: Boolean. If true a host tag is included. + * - instance: Boolean. If true a instance tag is included. + * - blacklisted-tags: List[String]. List of Environment tags that should not be included in the result. + * + * This utility is meant to be used mostly by reporter modules. + * + */ +object EnvironmentTagBuilder { + + def create(config: Config): Map[String, String] = + create(Kamon.environment, config) + + def create(env: Environment, config: Config): Map[String, String] = { + val envTags = Map.newBuilder[String, String] + + if(config.getBoolean("service")) + envTags += ("service" -> env.service) + + if(config.getBoolean("host")) + envTags += ("host" -> env.host) + + if(config.getBoolean("instance")) + envTags += ("instance" -> env.instance) + + val blacklistedTags = config.getStringList("blacklisted-tags").asScala + env.tags.filterKeys(k => !blacklistedTags.contains(k)).foreach(p => envTags += p) + + envTags.result() + } +} -- cgit v1.2.3