diff options
author | Ivan Topolnjak <ivantopo@gmail.com> | 2018-08-30 13:25:10 +0200 |
---|---|---|
committer | Ivan Topolnjak <ivantopo@gmail.com> | 2018-08-30 13:25:10 +0200 |
commit | d30ff29cdb5f94be34163d851d71716a316bdf10 (patch) | |
tree | c49ef34299f14ac281a2cf06e93484db65c3ac13 /kamon-core/src/main/scala | |
parent | e4abea098ef4d6e71a805812bfa95c14bd9002b5 (diff) | |
download | Kamon-d30ff29cdb5f94be34163d851d71716a316bdf10.tar.gz Kamon-d30ff29cdb5f94be34163d851d71716a316bdf10.tar.bz2 Kamon-d30ff29cdb5f94be34163d851d71716a316bdf10.zip |
mockup definition on the HTTP Server instrumentation configuration
Diffstat (limited to 'kamon-core/src/main/scala')
-rw-r--r-- | kamon-core/src/main/scala/kamon/ContextPropagation.scala | 17 |
1 files changed, 6 insertions, 11 deletions
diff --git a/kamon-core/src/main/scala/kamon/ContextPropagation.scala b/kamon-core/src/main/scala/kamon/ContextPropagation.scala index 518aa021..bfcfbf7e 100644 --- a/kamon-core/src/main/scala/kamon/ContextPropagation.scala +++ b/kamon-core/src/main/scala/kamon/ContextPropagation.scala @@ -40,8 +40,8 @@ trait ContextPropagation { self: Configuration with ClassLoading => } object ContextPropagation { - val DefaultHttpChannel = "http" - val DefaultBinaryChannel = "binary" + val DefaultHttpChannel = "default" + val DefaultBinaryChannel = "default" case class Components( httpChannels: Map[String, HttpPropagation] @@ -51,17 +51,12 @@ object ContextPropagation { def from(config: Config, classLoading: ClassLoading): Components = { val propagationConfig = config.getConfig("kamon.propagation") - val channels = propagationConfig.getConfig("channels").configurations - - val httpChannels = Map.newBuilder[String, HttpPropagation] - - channels.foreach { - case (channelName, channelConfig) => channelConfig.getString("type") match { - case "http" => httpChannels += (channelName -> HttpPropagation.from(channelConfig, classLoading)) - } + val httpChannelsConfig = propagationConfig.getConfig("http").configurations + val httpChannels = httpChannelsConfig.map { + case (channelName, channelConfig) => (channelName -> HttpPropagation.from(channelConfig, classLoading)) } - Components(httpChannels.result()) + Components(httpChannels) } } } |