|
16 | 16 |
|
17 | 17 | package com.expedia.www.haystack.trace.reader.readers.utils |
18 | 18 |
|
19 | | -import com.expedia.open.tracing.{Log, Span, Tag} |
| 19 | +import com.expedia.open.tracing.Log |
| 20 | +import com.expedia.open.tracing.Span |
| 21 | +import com.expedia.open.tracing.Tag |
20 | 22 | import com.expedia.www.haystack.trace.reader.readers.utils.SpanMarkers._ |
21 | 23 |
|
22 | 24 | import scala.collection.JavaConverters._ |
@@ -45,20 +47,23 @@ object SpanUtils { |
45 | 47 | } |
46 | 48 |
|
47 | 49 | def getEffectiveServiceName(span: Span): String = { |
48 | | - if(containsServiceTag(span)) { |
49 | | - val serviceTagValue = span.getTagsList.asScala.find(_.getKey == SERVICE_TAG_KEY).map(_.getVStr).get |
50 | | - if(serviceTagValue == "") { // Span protobuf-generated code returns empty string for a missing tag key |
51 | | - span.getServiceName |
52 | | - } else { |
53 | | - serviceTagValue |
54 | | - } |
55 | | - } else { |
| 50 | + val serviceTag = getServiceTag(span) |
| 51 | + if (serviceTag.isDefined) { |
| 52 | + val serviceTagValue = serviceTag.get.getVStr |
| 53 | + if (serviceTagValue == "") { // Span protobuf-generated code returns empty string for a missing tag key |
56 | 54 | span.getServiceName |
| 55 | + } else { |
| 56 | + serviceTagValue |
57 | 57 | } |
58 | | - } |
| 58 | + } else { |
| 59 | + span.getServiceName |
| 60 | + } |
| 61 | + } |
59 | 62 |
|
60 | | - def containsServiceTag(span: Span): Boolean = { |
61 | | - containsTag(span, SERVICE_TAG_KEY) |
| 63 | + def getServiceTag(span: Span): Option[Tag] = { |
| 64 | + span.getTagsList.asScala.find(tag => { |
| 65 | + tag.getKey.equalsIgnoreCase(SERVICE_TAG_KEY) |
| 66 | + }) |
62 | 67 | } |
63 | 68 |
|
64 | 69 | def containsClientLogTag(span: Span): Boolean = { |
@@ -109,12 +114,6 @@ object SpanUtils { |
109 | 114 | }) |
110 | 115 | } |
111 | 116 |
|
112 | | - private def containsTag(span: Span, key: String) = { |
113 | | - span.getTagsList.asScala.exists(tag => { |
114 | | - tag.getKey.equalsIgnoreCase(key) |
115 | | - }) |
116 | | - } |
117 | | - |
118 | 117 | def createAutoGeneratedRootSpan(spans: Seq[Span], |
119 | 118 | reason: String, |
120 | 119 | rootSpanId: String): Span.Builder = { |
|
0 commit comments