Skip to content

Commit

Permalink
nullable instrumentation version
Browse files Browse the repository at this point in the history
  • Loading branch information
Mateusz Rzeszutek committed Apr 5, 2022
1 parent 8ef3cbd commit d0ca736
Showing 1 changed file with 10 additions and 11 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ public final class InstrumenterBuilder<REQUEST, RESPONSE> {
private final List<RequestListener> requestListeners = new ArrayList<>();
private final List<RequestMetrics> requestMetrics = new ArrayList<>();

private String instrumentationVersion;
@Nullable private String instrumentationVersion;
@Nullable private String schemaUrl = null;
SpanKindExtractor<? super REQUEST> spanKindExtractor = SpanKindExtractor.alwaysInternal();
SpanStatusExtractor<? super REQUEST, ? super RESPONSE> spanStatusExtractor =
Expand All @@ -69,9 +69,9 @@ public final class InstrumenterBuilder<REQUEST, RESPONSE> {
SpanNameExtractor<? super REQUEST> spanNameExtractor) {
this.openTelemetry = openTelemetry;
this.instrumentationName = instrumentationName;
this.spanNameExtractor = spanNameExtractor;
this.instrumentationVersion =
EmbeddedInstrumentationProperties.findVersion(instrumentationName);
this.spanNameExtractor = spanNameExtractor;
}

/**
Expand Down Expand Up @@ -288,10 +288,10 @@ private Instrumenter<REQUEST, RESPONSE> newInstrumenter(

Tracer buildTracer() {
TracerBuilder tracerBuilder =
openTelemetry
.getTracerProvider()
.tracerBuilder(instrumentationName)
.setInstrumentationVersion(instrumentationVersion);
openTelemetry.getTracerProvider().tracerBuilder(instrumentationName);
if (instrumentationVersion != null) {
tracerBuilder.setInstrumentationVersion(instrumentationVersion);
}
if (schemaUrl != null) {
tracerBuilder.setSchemaUrl(schemaUrl);
}
Expand All @@ -303,11 +303,10 @@ List<RequestListener> buildRequestListeners() {
new ArrayList<>(requestListeners.size() + requestMetrics.size());
listeners.addAll(requestListeners);

MeterBuilder meterBuilder =
openTelemetry
.getMeterProvider()
.meterBuilder(instrumentationName)
.setInstrumentationVersion(instrumentationVersion);
MeterBuilder meterBuilder = openTelemetry.getMeterProvider().meterBuilder(instrumentationName);
if (instrumentationVersion != null) {
meterBuilder.setInstrumentationVersion(instrumentationVersion);
}
if (schemaUrl != null) {
meterBuilder.setSchemaUrl(schemaUrl);
}
Expand Down

0 comments on commit d0ca736

Please sign in to comment.