blob: 570f64dd477d2dc3abdd9713fbd239d9f13fa2ad (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
|
package kamon.instrumentation
import scala.concurrent.{Await, Promise, Future}
import org.scalatest.{Matchers, OptionValues, WordSpec}
import org.scalatest.concurrent.{ScalaFutures, PatienceConfiguration}
import kamon.{Tracer, Kamon}
import java.util.UUID
import scala.util.Success
import scala.concurrent.duration._
import java.util.concurrent.TimeUnit
import akka.actor.ActorSystem
import kamon.trace.TraceContext
class RunnableInstrumentationSpec extends WordSpec with Matchers with ScalaFutures with PatienceConfiguration with OptionValues {
"a instrumented runnable" when {
"created in a thread that does have a TraceContext" must {
"preserve the TraceContext" which {
"should be available during the run method execution" in new FutureWithContextFixture {
whenReady(futureWithContext) { result =>
result.value should equal(testContext)
}
}
"should be available during the execution of onComplete callbacks" in new FutureWithContextFixture {
val onCompleteContext = Promise[Option[TraceContext]]()
Tracer.traceContext.withValue(Some(testContext)) {
futureWithContext.onComplete({
case _ => println("Completing second promise from: "+Thread.currentThread().getName + " With Context: " + Tracer.traceContext.value); onCompleteContext.complete(Success(Tracer.traceContext.value))
})
}
whenReady(onCompleteContext.future) { result =>
result should equal(Some(testContext))
}
}
}
}
"created in a thread that doest have a TraceContext" must {
"not capture any TraceContext for the body execution" in new FutureWithoutContextFixture{
whenReady(futureWithoutContext) { result =>
result should equal(None)
}
}
"not make any TraceContext available during the onComplete callback" in new FutureWithoutContextFixture {
val onCompleteContext = Promise[Option[TraceContext]]()
futureWithoutContext.onComplete {
case _ => onCompleteContext.complete(Success(Tracer.traceContext.value))
}
whenReady(onCompleteContext.future) { result =>
result should equal(None)
}
}
}
}
/**
* We are using Futures for the test since they exercise Runnables in the back and also resemble the real use case we have.
*/
implicit val testActorSystem = ActorSystem("test-actorsystem")
implicit val execContext = testActorSystem.dispatcher
class FutureWithContextFixture {
val testContext = TraceContext()
var futureWithContext: Future[Option[TraceContext]] = _
Tracer.traceContext.withValue(Some(testContext)) {
futureWithContext = Future { Tracer.traceContext.value }
}
}
trait FutureWithoutContextFixture {
val futureWithoutContext = Future { Tracer.traceContext.value }
}
}
|
