aboutsummaryrefslogtreecommitdiff
path: root/kamon-core/src/main/scala/kamon/trace/ActiveSpanSource.scala
diff options
context:
space:
mode:
authorIvan Topolnjak <ivantopo@gmail.com>2017-07-30 11:25:11 +0200
committerIvan Topolnjak <ivantopo@gmail.com>2017-07-30 11:25:11 +0200
commit18b9fc25d556fef50c5033f8880fab2594783caa (patch)
treef9357c04000adb4ee06efb1cc2d3418f7a8d9310 /kamon-core/src/main/scala/kamon/trace/ActiveSpanSource.scala
parent0930e36def6ce62c55d30d744b41ef475374a541 (diff)
downloadKamon-18b9fc25d556fef50c5033f8880fab2594783caa.tar.gz
Kamon-18b9fc25d556fef50c5033f8880fab2594783caa.tar.bz2
Kamon-18b9fc25d556fef50c5033f8880fab2594783caa.zip
rename ActiveSpanSource into ActiveSpanStorage
Diffstat (limited to 'kamon-core/src/main/scala/kamon/trace/ActiveSpanSource.scala')
-rw-r--r--kamon-core/src/main/scala/kamon/trace/ActiveSpanSource.scala46
1 files changed, 0 insertions, 46 deletions
diff --git a/kamon-core/src/main/scala/kamon/trace/ActiveSpanSource.scala b/kamon-core/src/main/scala/kamon/trace/ActiveSpanSource.scala
deleted file mode 100644
index f4a363a6..00000000
--- a/kamon-core/src/main/scala/kamon/trace/ActiveSpanSource.scala
+++ /dev/null
@@ -1,46 +0,0 @@
-package kamon.trace
-
-
-trait Scope extends AutoCloseable {
- def close(): Unit
-}
-
-trait ActiveSpanSource {
- def activeSpan(): Span
-
- def activate(span: Span): Scope
- def activate(span: Span, finishOnClose: Boolean): Scope
-}
-
-object ActiveSpanSource {
-
- final class ThreadLocalBased extends ActiveSpanSource {
- private val emptySpan = Span.Empty(this)
- private val storage: ThreadLocal[Span] = new ThreadLocal[Span] {
- override def initialValue(): Span = emptySpan
- }
-
- override def activeSpan(): Span =
- storage.get()
-
- override def activate(span: Span): Scope =
- activate(span, finishOnClose = false)
-
- override def activate(span: Span, finishOnClose: Boolean): Scope = {
- val previouslyActiveSpan = storage.get()
- storage.set(span)
-
- new Scope {
- override def close(): Unit = {
- storage.set(previouslyActiveSpan)
- if (finishOnClose && span != null)
- span.finish()
- }
- }
- }
- }
-
- object ThreadLocalBased {
- def apply(): ThreadLocalBased = new ThreadLocalBased()
- }
-} \ No newline at end of file