diff options
| author | Ivan Topolnjak <ivantopo@gmail.com> | 2017-07-12 12:35:33 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-07-12 12:35:33 +0200 |
| commit | ac3b72e27765ceec4cc3958b0fa7eaba0299f017 (patch) | |
| tree | 11cfe2100a59ab6af800293707ab6266dd2195ec /kamon-core/src/main/scala | |
| parent | 52c4503b6aea2309feeb550b7db2e5fa627dedc8 (diff) | |
| parent | 6c0a8fb6395fca11b48f7ad1cd2bd774f90ee7fd (diff) | |
| download | Kamon-ac3b72e27765ceec4cc3958b0fa7eaba0299f017.tar.gz Kamon-ac3b72e27765ceec4cc3958b0fa7eaba0299f017.tar.bz2 Kamon-ac3b72e27765ceec4cc3958b0fa7eaba0299f017.zip | |
Merge pull request #479 from mladens/kamon-1.0-develop
Kamon 1.0 develop
Diffstat (limited to 'kamon-core/src/main/scala')
| -rw-r--r-- | kamon-core/src/main/scala/kamon/trace/Span.scala | 16 |
1 files changed, 10 insertions, 6 deletions
diff --git a/kamon-core/src/main/scala/kamon/trace/Span.scala b/kamon-core/src/main/scala/kamon/trace/Span.scala index 8149be74..464559e3 100644 --- a/kamon-core/src/main/scala/kamon/trace/Span.scala +++ b/kamon-core/src/main/scala/kamon/trace/Span.scala @@ -153,14 +153,18 @@ class Span(spanContext: SpanContext, initialOperationName: String, initialTags: val elapsedTime = endTimestampMicros - startTimestampMicros val metricTags = Map("operation" -> operationName) ++ additionalMetricTags - val latencyHistogram = Span.Metrics.SpanProcessingTimeMetric.refine(metricTags) - latencyHistogram.record(elapsedTime) + val isError = tags.get("error").exists { + errorTag => errorTag != null && errorTag.equals(Span.BooleanTagTrueValue) + } - tags.get("error").foreach { errorTag => - if(errorTag != null && errorTag.equals(Span.BooleanTagTrueValue)) { - Span.Metrics.SpanErrorCount.refine(metricTags).increment() - } + val refinedTags = if(isError) { + metricTags + ("error" -> Span.BooleanTagTrueValue) + } else { + metricTags } + + val latencyHistogram = Span.Metrics.SpanProcessingTimeMetric.refine(refinedTags) + latencyHistogram.record(elapsedTime) } } |