5 files changed, 0 insertions, 171 deletions
diff --git a/kamon-core/src/test/scala/kamon/testkit/MetricInspection.scala b/kamon-core/src/test/scala/kamon/testkit/MetricInspection.scala
deleted file mode 100644
index d0681fb5..00000000
--- a/kamon-core/src/test/scala/kamon/testkit/MetricInspection.scala
+++ /dev/null
@@ -1,45 +0,0 @@
-package kamon.testkit
-
-import kamon.metric._
-import _root_.scala.collection.concurrent.TrieMap
-
-
-trait MetricInspection {
-
-  implicit class MetricSyntax(metric: Metric[_]) {
-    def valuesForTag(tag: String): Seq[String] = {
-      val instrumentsField = classOf[BaseMetric[_, _]].getDeclaredField("instruments")
-      instrumentsField.setAccessible(true)
-
-      val instruments = instrumentsField.get(metric).asInstanceOf[TrieMap[Map[String, String], _]]
-      val instrumentsWithTheTag = instruments.keys.filter(_.keys.find(_ == tag).nonEmpty)
-      instrumentsWithTheTag.map(t => t(tag)).toSeq
-    }
-  }
-
-  implicit class HistogramMetricSyntax(histogram: Histogram) {
-    def distribution(resetState: Boolean = true): Distribution =
-      histogram match {
-        case hm: HistogramMetric    => hm.refine(Map.empty[String, String]).distribution(resetState)
-        case h: AtomicHdrHistogram  => h.snapshot(resetState).distribution
-        case h: HdrHistogram        => h.snapshot(resetState).distribution
-      }
-  }
-
-  implicit class MinMaxCounterMetricSyntax(mmCounter: MinMaxCounter) {
-    def distribution(resetState: Boolean = true): Distribution =
-      mmCounter match {
-        case mmcm: MinMaxCounterMetric  => mmcm.refine(Map.empty[String, String]).distribution(resetState)
-        case mmc: SimpleMinMaxCounter   => mmc.snapshot(resetState).distribution
-      }
-  }
-
-  implicit class CounterMetricSyntax(counter: Counter) {
-    def value(resetState: Boolean = true): Long =
-      counter match {
-        case cm: CounterMetric    => cm.refine(Map.empty[String, String]).value(resetState)
-        case c: LongAdderCounter  => c.snapshot(resetState).value
-      }
-  }
-}
-
diff --git a/kamon-core/src/test/scala/kamon/testkit/Reconfigure.scala b/kamon-core/src/test/scala/kamon/testkit/Reconfigure.scala
deleted file mode 100644
index 4b3b2cdb..00000000
--- a/kamon-core/src/test/scala/kamon/testkit/Reconfigure.scala
+++ /dev/null
@@ -1,26 +0,0 @@
-package kamon.testkit
-
-import com.typesafe.config.ConfigFactory
-import kamon.Kamon
-
-trait Reconfigure {
-
-  def enableFastSpanFlushing(): Unit = {
-    applyConfig("kamon.trace.tick-interval = 1 millisecond")
-  }
-
-  def sampleAlways(): Unit = {
-    applyConfig("kamon.trace.sampler = always")
-  }
-
-  def sampleNever(): Unit = {
-    applyConfig("kamon.trace.sampler = never")
-  }
-
-  private def applyConfig(configString: String): Unit = {
-    Kamon.reconfigure(ConfigFactory.parseString(configString).withFallback(Kamon.config()))
-  }
-
-
-
-}
diff --git a/kamon-core/src/test/scala/kamon/testkit/SpanBuilding.scala b/kamon-core/src/test/scala/kamon/testkit/SpanBuilding.scala
deleted file mode 100644
index 7a216ecc..00000000
--- a/kamon-core/src/test/scala/kamon/testkit/SpanBuilding.scala
+++ /dev/null
@@ -1,16 +0,0 @@
-package kamon.testkit
-
-import kamon.trace.SpanContext.SamplingDecision
-import kamon.trace.{IdentityProvider, SpanContext}
-
-trait SpanBuilding {
-  private val identityProvider = IdentityProvider.Default()
-
-  def createSpanContext(samplingDecision: SamplingDecision = SamplingDecision.Sample): SpanContext =
-    SpanContext(
-      traceID = identityProvider.traceIdGenerator().generate(),
-      spanID = identityProvider.spanIdGenerator().generate(),
-      parentID = identityProvider.spanIdGenerator().generate(),
-      samplingDecision = samplingDecision
-    )
-}
diff --git a/kamon-core/src/test/scala/kamon/testkit/SpanInspector.scala b/kamon-core/src/test/scala/kamon/testkit/SpanInspector.scala
deleted file mode 100644
index f23fba98..00000000
--- a/kamon-core/src/test/scala/kamon/testkit/SpanInspector.scala
+++ /dev/null
@@ -1,61 +0,0 @@
-package kamon.testkit
-
-import kamon.trace.{Span, SpanContext}
-import kamon.trace.Span.FinishedSpan
-import kamon.util.Clock
-
-import scala.reflect.ClassTag
-import scala.util.Try
-
-class SpanInspector(span: Span) {
-  private val (realSpan, spanData) = Try {
-    val realSpan = span match {
-      case _: Span.Local => span
-    }
-
-    val spanData = invoke[Span.Local, FinishedSpan](realSpan, "toFinishedSpan", classOf[Long] -> Long.box(Clock.microTimestamp()))
-    (realSpan, spanData)
-  }.getOrElse((null, null))
-
-  def isEmpty: Boolean =
-    realSpan == null
-
-  def spanTag(key: String): Option[Span.TagValue] =
-    spanData.tags.get(key)
-
-  def spanTags(): Map[String, Span.TagValue] =
-    spanData.tags
-
-  def metricTags(): Map[String, String] =
-    getField[Span.Local, Map[String, String]](realSpan, "customMetricTags")
-
-  def startTimestamp(): Long =
-    getField[Span.Local, Long](realSpan, "startTimestampMicros")
-
-  def context(): SpanContext =
-    spanData.context
-
-  def operationName(): String =
-    spanData.operationName
-
-
-
-
-  private def getField[T, R](target: Any, fieldName: String)(implicit classTag: ClassTag[T]): R = {
-    val toFinishedSpanMethod = classTag.runtimeClass.getDeclaredField(fieldName)
-    toFinishedSpanMethod.setAccessible(true)
-    toFinishedSpanMethod.get(target).asInstanceOf[R]
-  }
-
-  private def invoke[T, R](target: Any, fieldName: String, parameters: (Class[_], AnyRef)*)(implicit classTag: ClassTag[T]): R = {
-    val parameterClasses = parameters.map(_._1)
-    val parameterInstances = parameters.map(_._2)
-    val toFinishedSpanMethod = classTag.runtimeClass.getDeclaredMethod(fieldName, parameterClasses: _*)
-    toFinishedSpanMethod.setAccessible(true)
-    toFinishedSpanMethod.invoke(target, parameterInstances: _*).asInstanceOf[R]
-  }
-}
-
-object SpanInspector {
-  def apply(span: Span): SpanInspector = new SpanInspector(span)
-}
diff --git a/kamon-core/src/test/scala/kamon/testkit/TestSpanReporter.scala b/kamon-core/src/test/scala/kamon/testkit/TestSpanReporter.scala
deleted file mode 100644
index 8ea2d433..00000000
--- a/kamon-core/src/test/scala/kamon/testkit/TestSpanReporter.scala
+++ /dev/null
@@ -1,23 +0,0 @@
-package kamon.testkit
-
-import java.util.concurrent.LinkedBlockingQueue
-
-import com.typesafe.config.Config
-import kamon.SpanReporter
-import kamon.trace.Span
-import kamon.trace.Span.FinishedSpan
-
-class TestSpanReporter() extends SpanReporter {
-  import scala.collection.JavaConverters._
-  private val reportedSpans = new LinkedBlockingQueue[FinishedSpan]()
-
-  override def reportSpans(spans: Seq[Span.FinishedSpan]): Unit =
-    reportedSpans.addAll(spans.asJava)
-
-  def nextSpan(): Option[FinishedSpan] =
-    Option(reportedSpans.poll())
-
-  override def start(): Unit = {}
-  override def stop(): Unit = {}
-  override def reconfigure(config: Config): Unit = {}
-}