aboutsummaryrefslogtreecommitdiff
path: root/kamon-core/src/main/scala/kamon/trace/TracingContext.scala
diff options
context:
space:
mode:
Diffstat (limited to 'kamon-core/src/main/scala/kamon/trace/TracingContext.scala')
-rw-r--r--kamon-core/src/main/scala/kamon/trace/TracingContext.scala14
1 files changed, 9 insertions, 5 deletions
diff --git a/kamon-core/src/main/scala/kamon/trace/TracingContext.scala b/kamon-core/src/main/scala/kamon/trace/TracingContext.scala
index 4cada1d0..1ea35526 100644
--- a/kamon-core/src/main/scala/kamon/trace/TracingContext.scala
+++ b/kamon-core/src/main/scala/kamon/trace/TracingContext.scala
@@ -20,11 +20,12 @@ import java.util.concurrent.ConcurrentLinkedQueue
import java.util.concurrent.atomic.AtomicInteger
import akka.event.LoggingAdapter
-import kamon.util.{ NanoInterval, NanoTimestamp, RelativeNanoTimestamp }
+import kamon.util.{NanoInterval, NanoTimestamp, RelativeNanoTimestamp}
import scala.collection.concurrent.TrieMap
-private[trace] class TracingContext(traceName: String,
+private[trace] class TracingContext(
+ traceName: String,
token: String,
tags: Map[String, String],
currentStatus: Status,
@@ -32,7 +33,8 @@ private[trace] class TracingContext(traceName: String,
isLocal: Boolean,
startTimeztamp: RelativeNanoTimestamp,
log: LoggingAdapter,
- traceInfoSink: TracingContext ⇒ Unit) extends MetricsOnlyContext(traceName, token, tags, currentStatus, levelOfDetail, startTimeztamp, log) {
+ traceInfoSink: TracingContext ⇒ Unit
+) extends MetricsOnlyContext(traceName, token, tags, currentStatus, levelOfDetail, startTimeztamp, log) {
private val _openSegments = new AtomicInteger(0)
private val _startTimestamp = NanoTimestamp.now
@@ -87,10 +89,12 @@ private[trace] class TracingContext(traceName: String,
TraceInfo(name, token, _startTimestamp, elapsedTime, _metadata.toMap, tags, segmentsInfo.result(), status)
}
- class TracingSegment(segmentName: String,
+ class TracingSegment(
+ segmentName: String,
category: String,
library: String,
- tags: Map[String, String]) extends MetricsOnlySegment(segmentName, category, library, tags) {
+ tags: Map[String, String]
+ ) extends MetricsOnlySegment(segmentName, category, library, tags) {
private val metadata = TrieMap.empty[String, String]
override def addMetadata(key: String, value: String): Unit = metadata.put(key, value)