diff options
author | Ivan Topolnjak <ivantopo@gmail.com> | 2017-05-18 16:21:44 +0200 |
---|---|---|
committer | Ivan Topolnjak <ivantopo@gmail.com> | 2017-05-18 16:21:44 +0200 |
commit | 77f2666650726352a9e15dcf6019064d91393b2e (patch) | |
tree | c39f7e2a18ac6bb1fcd1e2cc73dd3c165919515e /kamon-core/src/main/scala/kamon/trace/SpanContext.scala | |
parent | 5dee54a0794b282e9b5729a3d4b85478c12a68d1 (diff) | |
download | Kamon-77f2666650726352a9e15dcf6019064d91393b2e.tar.gz Kamon-77f2666650726352a9e15dcf6019064d91393b2e.tar.bz2 Kamon-77f2666650726352a9e15dcf6019064d91393b2e.zip |
some more wip
Diffstat (limited to 'kamon-core/src/main/scala/kamon/trace/SpanContext.scala')
-rw-r--r-- | kamon-core/src/main/scala/kamon/trace/SpanContext.scala | 21 |
1 files changed, 21 insertions, 0 deletions
diff --git a/kamon-core/src/main/scala/kamon/trace/SpanContext.scala b/kamon-core/src/main/scala/kamon/trace/SpanContext.scala new file mode 100644 index 00000000..7f5962e0 --- /dev/null +++ b/kamon-core/src/main/scala/kamon/trace/SpanContext.scala @@ -0,0 +1,21 @@ +package kamon.trace +import java.lang +import java.util.Map +import scala.collection.JavaConverters._ + +class SpanContext(val traceID: Long, val spanID: Long, val parentID: Long) extends io.opentracing.SpanContext { + private var baggage = scala.collection.immutable.Map.empty[String, String] + + private[kamon] def addBaggageItem(key: String, value: String): Unit = { + baggage = baggage + (key -> value) + } + + private[kamon] def getBaggage(key: String): String = + baggage.get(key).getOrElse(null) + + private[kamon] def baggageMap: scala.collection.immutable.Map[String, String] = + baggage + + override def baggageItems(): lang.Iterable[Map.Entry[String, String]] = + baggage.asJava.entrySet() +} |