aboutsummaryrefslogtreecommitdiff
path: root/kamon-core
diff options
context:
space:
mode:
authorIvan Topolnjak <ivantopo@gmail.com>2017-08-26 21:56:50 +0200
committerIvan Topolnjak <ivantopo@gmail.com>2017-08-26 21:56:50 +0200
commit194bc4fc90c53199eae6b6ca05964f7aa03bbdb3 (patch)
tree0409c77e8d1cbe30999eef6d96a5713d2c5ce320 /kamon-core
parent7d81f4ca59b2f22da7a23e825a3c562f3d9336a9 (diff)
downloadKamon-194bc4fc90c53199eae6b6ca05964f7aa03bbdb3.tar.gz
Kamon-194bc4fc90c53199eae6b6ca05964f7aa03bbdb3.tar.bz2
Kamon-194bc4fc90c53199eae6b6ca05964f7aa03bbdb3.zip
remove the annotations API from the Span
Diffstat (limited to 'kamon-core')
-rw-r--r--kamon-core/src/main/scala/kamon/trace/Span.scala25
1 files changed, 2 insertions, 23 deletions
diff --git a/kamon-core/src/main/scala/kamon/trace/Span.scala b/kamon-core/src/main/scala/kamon/trace/Span.scala
index 3158aa73..c359f8e0 100644
--- a/kamon-core/src/main/scala/kamon/trace/Span.scala
+++ b/kamon-core/src/main/scala/kamon/trace/Span.scala
@@ -33,8 +33,6 @@ trait Span {
def context(): SpanContext
- def annotate(annotation: Span.Annotation): Span
-
def addTag(key: String, value: String): Span
def addSpanTag(key: String, value: String): Span
@@ -54,15 +52,6 @@ trait Span {
def finish(): Unit =
finish(Clock.microTimestamp())
- def annotate(name: String): Span =
- annotate(Span.Annotation(Clock.microTimestamp(), name, Map.empty))
-
- def annotate(name: String, fields: Map[String, String]): Span =
- annotate(Span.Annotation(Clock.microTimestamp(), name, fields))
-
- def annotate(timestampMicroseconds: Long, name: String, fields: Map[String, String]): Span =
- annotate(Span.Annotation(timestampMicroseconds, name, fields))
-
}
object Span {
@@ -73,7 +62,6 @@ object Span {
override val context: SpanContext = SpanContext.EmptySpanContext
override def isEmpty(): Boolean = true
override def isLocal(): Boolean = true
- override def annotate(annotation: Annotation): Span = this
override def addTag(key: String, value: String): Span = this
override def addSpanTag(key: String, value: String): Span = this
override def addSpanTag(key: String, value: Long): Span = this
@@ -102,17 +90,10 @@ object Span {
private var spanTags: Map[String, Span.TagValue] = initialSpanTags
private var customMetricTags = initialMetricTags
- private var annotations = List.empty[Span.Annotation]
override def isEmpty(): Boolean = false
override def isLocal(): Boolean = true
- def annotate(annotation: Annotation): Span = synchronized {
- if(sampled && open)
- annotations = annotation :: annotations
- this
- }
-
override def addTag(key: String, value: String): Span = synchronized {
addSpanTag(key, value)
addMetricTag(key, value)
@@ -172,7 +153,7 @@ object Span {
}
private def toFinishedSpan(endTimestampMicros: Long): Span.FinishedSpan =
- Span.FinishedSpan(spanContext, operationName, startTimestampMicros, endTimestampMicros, spanTags, annotations)
+ Span.FinishedSpan(spanContext, operationName, startTimestampMicros, endTimestampMicros, spanTags)
private def recordSpanMetrics(endTimestampMicros: Long): Unit = {
val elapsedTime = endTimestampMicros - startTimestampMicros
@@ -204,7 +185,6 @@ object Span {
final class Remote(val context: SpanContext) extends Span {
override def isEmpty(): Boolean = false
override def isLocal(): Boolean = false
- override def annotate(annotation: Annotation): Span = this
override def addTag(key: String, value: String): Span = this
override def addSpanTag(key: String, value: String): Span = this
override def addSpanTag(key: String, value: Long): Span = this
@@ -251,7 +231,6 @@ object Span {
operationName: String,
startTimestampMicros: Long,
endTimestampMicros: Long,
- tags: Map[String, Span.TagValue],
- annotations: Seq[Annotation]
+ tags: Map[String, Span.TagValue]
)
} \ No newline at end of file