Skip to content

Commit 6c76996

Browse files
update MetricsAdapter to include exemplars (#748)
1 parent 6a2c29d commit 6c76996

File tree

1 file changed

+2
-13
lines changed

1 file changed

+2
-13
lines changed

Sources/Exporters/OpenTelemetryProtocolCommon/metric/MetricsAdapter.swift

Lines changed: 2 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -203,6 +203,7 @@ public enum MetricsAdapter {
203203
protoExemplar.spanID = TraceProtoUtils.toProtoSpanId(spanId: spanContext.spanId)
204204
protoExemplar.traceID = TraceProtoUtils.toProtoTraceId(traceId: spanContext.traceId)
205205
}
206+
protoPoint.exemplars.append(protoExemplar)
206207
}
207208
}
208209

@@ -225,6 +226,7 @@ public enum MetricsAdapter {
225226
protoExemplar.spanID = TraceProtoUtils.toProtoSpanId(spanId: spanContext.spanId)
226227
protoExemplar.traceID = TraceProtoUtils.toProtoTraceId(traceId: spanContext.traceId)
227228
}
229+
protoPoint.exemplars.append(protoExemplar)
228230
}
229231
}
230232

@@ -235,19 +237,6 @@ public enum MetricsAdapter {
235237
pointData.attributes.forEach {
236238
protoPoint.attributes.append(CommonAdapter.toProtoAttribute(key: $0.key, attributeValue: $0.value))
237239
}
238-
239-
pointData.exemplars.forEach {
240-
var protoExemplar = Opentelemetry_Proto_Metrics_V1_Exemplar()
241-
protoExemplar.timeUnixNano = $0.epochNanos
242-
243-
$0.filteredAttributes.forEach {
244-
protoExemplar.filteredAttributes.append(CommonAdapter.toProtoAttribute(key: $0.key, attributeValue: $0.value))
245-
}
246-
if let spanContext = $0.spanContext {
247-
protoExemplar.spanID = TraceProtoUtils.toProtoSpanId(spanId: spanContext.spanId)
248-
protoExemplar.traceID = TraceProtoUtils.toProtoTraceId(traceId: spanContext.traceId)
249-
}
250-
}
251240
}
252241

253242
static func injectPointData(protoNumberPoint protoPoint: inout Opentelemetry_Proto_Metrics_V1_NumberDataPoint, pointData: PointData) {

0 commit comments

Comments
 (0)