blob: 570f64dd477d2dc3abdd9713fbd239d9f13fa2ad (
plain) (
tree)
|
|
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 }
}
}
|