Use OtelVersionClassPlugin instead of reading version from resource (#5622)
This commit is contained in:
parent
16e7113dcc
commit
b0c5c04181
|
|
@ -1,7 +1,10 @@
|
||||||
|
import io.opentelemetry.gradle.OtelVersionClassPlugin
|
||||||
|
|
||||||
plugins {
|
plugins {
|
||||||
id("otel.java-conventions")
|
id("otel.java-conventions")
|
||||||
id("otel.publish-conventions")
|
id("otel.publish-conventions")
|
||||||
}
|
}
|
||||||
|
apply<OtelVersionClassPlugin>()
|
||||||
|
|
||||||
description = "OpenTelemetry OpenCensus Shim"
|
description = "OpenTelemetry OpenCensus Shim"
|
||||||
otelJava.moduleName.set("io.opentelemetry.opencensusshim")
|
otelJava.moduleName.set("io.opentelemetry.opencensusshim")
|
||||||
|
|
|
||||||
|
|
@ -41,18 +41,17 @@ import io.opentelemetry.api.GlobalOpenTelemetry;
|
||||||
import io.opentelemetry.api.trace.SpanKind;
|
import io.opentelemetry.api.trace.SpanKind;
|
||||||
import io.opentelemetry.api.trace.Tracer;
|
import io.opentelemetry.api.trace.Tracer;
|
||||||
import io.opentelemetry.context.Context;
|
import io.opentelemetry.context.Context;
|
||||||
|
import io.opentelemetry.sdk.common.internal.OtelVersion;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.Collections;
|
import java.util.Collections;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Properties;
|
|
||||||
import java.util.Random;
|
import java.util.Random;
|
||||||
import javax.annotation.Nullable;
|
import javax.annotation.Nullable;
|
||||||
|
|
||||||
class OpenTelemetrySpanBuilderImpl extends SpanBuilder {
|
class OpenTelemetrySpanBuilderImpl extends SpanBuilder {
|
||||||
|
|
||||||
private static final String OPENCENSUSSHIM_VERSION = readVersion();
|
|
||||||
private static final Tracer OTEL_TRACER =
|
private static final Tracer OTEL_TRACER =
|
||||||
GlobalOpenTelemetry.getTracer("io.opentelemetry.opencensusshim", OPENCENSUSSHIM_VERSION);
|
GlobalOpenTelemetry.getTracer("io.opentelemetry.opencensusshim", OtelVersion.VERSION);
|
||||||
private static final Tracestate OC_TRACESTATE_DEFAULT = Tracestate.builder().build();
|
private static final Tracestate OC_TRACESTATE_DEFAULT = Tracestate.builder().build();
|
||||||
private static final TraceOptions OC_SAMPLED_TRACE_OPTIONS =
|
private static final TraceOptions OC_SAMPLED_TRACE_OPTIONS =
|
||||||
TraceOptions.builder().setIsSampled(true).build();
|
TraceOptions.builder().setIsSampled(true).build();
|
||||||
|
|
@ -212,20 +211,6 @@ class OpenTelemetrySpanBuilderImpl extends SpanBuilder {
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
private static String readVersion() {
|
|
||||||
Properties properties = new Properties();
|
|
||||||
String version;
|
|
||||||
try {
|
|
||||||
properties.load(
|
|
||||||
OpenTelemetrySpanBuilderImpl.class.getResourceAsStream(
|
|
||||||
"/io/opentelemetry/opencensusshim/version.properties"));
|
|
||||||
version = properties.getProperty("sdk.version", "unknown");
|
|
||||||
} catch (Exception e) {
|
|
||||||
version = "unknown";
|
|
||||||
}
|
|
||||||
return version;
|
|
||||||
}
|
|
||||||
|
|
||||||
static final class Options {
|
static final class Options {
|
||||||
private final RandomHandler randomHandler;
|
private final RandomHandler randomHandler;
|
||||||
private final TraceConfig traceConfig;
|
private final TraceConfig traceConfig;
|
||||||
|
|
|
||||||
|
|
@ -1,7 +1,10 @@
|
||||||
|
import io.opentelemetry.gradle.OtelVersionClassPlugin
|
||||||
|
|
||||||
plugins {
|
plugins {
|
||||||
id("otel.java-conventions")
|
id("otel.java-conventions")
|
||||||
id("otel.publish-conventions")
|
id("otel.publish-conventions")
|
||||||
}
|
}
|
||||||
|
apply<OtelVersionClassPlugin>()
|
||||||
|
|
||||||
description = "OpenTelemetry OpenTracing Bridge"
|
description = "OpenTelemetry OpenTracing Bridge"
|
||||||
otelJava.moduleName.set("io.opentelemetry.opentracingshim")
|
otelJava.moduleName.set("io.opentelemetry.opentracingshim")
|
||||||
|
|
|
||||||
|
|
@ -7,6 +7,7 @@ package io.opentelemetry.opentracingshim;
|
||||||
|
|
||||||
import io.opentelemetry.api.trace.TracerProvider;
|
import io.opentelemetry.api.trace.TracerProvider;
|
||||||
import io.opentelemetry.context.propagation.TextMapPropagator;
|
import io.opentelemetry.context.propagation.TextMapPropagator;
|
||||||
|
import io.opentelemetry.opentracing.shim.internal.OtelVersion;
|
||||||
import io.opentracing.Scope;
|
import io.opentracing.Scope;
|
||||||
import io.opentracing.ScopeManager;
|
import io.opentracing.ScopeManager;
|
||||||
import io.opentracing.Span;
|
import io.opentracing.Span;
|
||||||
|
|
@ -18,7 +19,6 @@ import io.opentracing.propagation.TextMapInject;
|
||||||
import java.io.Closeable;
|
import java.io.Closeable;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.lang.reflect.Field;
|
import java.lang.reflect.Field;
|
||||||
import java.util.Properties;
|
|
||||||
import java.util.concurrent.atomic.AtomicBoolean;
|
import java.util.concurrent.atomic.AtomicBoolean;
|
||||||
import java.util.logging.Level;
|
import java.util.logging.Level;
|
||||||
import java.util.logging.Logger;
|
import java.util.logging.Logger;
|
||||||
|
|
@ -27,8 +27,6 @@ import javax.annotation.Nullable;
|
||||||
final class TracerShim implements Tracer {
|
final class TracerShim implements Tracer {
|
||||||
private static final Logger logger = Logger.getLogger(TracerShim.class.getName());
|
private static final Logger logger = Logger.getLogger(TracerShim.class.getName());
|
||||||
|
|
||||||
static final String OPENTRACINGSHIM_VERSION = readVersion();
|
|
||||||
|
|
||||||
private final io.opentelemetry.api.trace.TracerProvider provider;
|
private final io.opentelemetry.api.trace.TracerProvider provider;
|
||||||
private final io.opentelemetry.api.trace.Tracer tracer;
|
private final io.opentelemetry.api.trace.Tracer tracer;
|
||||||
private final ScopeManager scopeManagerShim;
|
private final ScopeManager scopeManagerShim;
|
||||||
|
|
@ -40,7 +38,7 @@ final class TracerShim implements Tracer {
|
||||||
TextMapPropagator textMapPropagator,
|
TextMapPropagator textMapPropagator,
|
||||||
TextMapPropagator httpPropagator) {
|
TextMapPropagator httpPropagator) {
|
||||||
this.provider = provider;
|
this.provider = provider;
|
||||||
this.tracer = provider.get("opentracing-shim", OPENTRACINGSHIM_VERSION);
|
this.tracer = provider.get("opentracing-shim", OtelVersion.VERSION);
|
||||||
this.propagation = new Propagation(textMapPropagator, httpPropagator);
|
this.propagation = new Propagation(textMapPropagator, httpPropagator);
|
||||||
this.scopeManagerShim = new ScopeManagerShim();
|
this.scopeManagerShim = new ScopeManagerShim();
|
||||||
}
|
}
|
||||||
|
|
@ -150,18 +148,4 @@ final class TracerShim implements Tracer {
|
||||||
}
|
}
|
||||||
return tracerProvider;
|
return tracerProvider;
|
||||||
}
|
}
|
||||||
|
|
||||||
private static String readVersion() {
|
|
||||||
Properties properties = new Properties();
|
|
||||||
String version;
|
|
||||||
try {
|
|
||||||
properties.load(
|
|
||||||
TracerShim.class.getResourceAsStream(
|
|
||||||
"/io/opentelemetry/opentracingshim/version.properties"));
|
|
||||||
version = properties.getProperty("sdk.version", "unknown");
|
|
||||||
} catch (Exception e) {
|
|
||||||
version = "unknown";
|
|
||||||
}
|
|
||||||
return version;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -14,6 +14,7 @@ import io.opentelemetry.api.OpenTelemetry;
|
||||||
import io.opentelemetry.api.trace.TracerProvider;
|
import io.opentelemetry.api.trace.TracerProvider;
|
||||||
import io.opentelemetry.context.propagation.ContextPropagators;
|
import io.opentelemetry.context.propagation.ContextPropagators;
|
||||||
import io.opentelemetry.context.propagation.TextMapPropagator;
|
import io.opentelemetry.context.propagation.TextMapPropagator;
|
||||||
|
import io.opentelemetry.sdk.common.internal.OtelVersion;
|
||||||
import io.opentelemetry.sdk.trace.SdkTracerProvider;
|
import io.opentelemetry.sdk.trace.SdkTracerProvider;
|
||||||
import io.opentracing.propagation.Format;
|
import io.opentracing.propagation.Format;
|
||||||
import org.junit.jupiter.api.AfterEach;
|
import org.junit.jupiter.api.AfterEach;
|
||||||
|
|
@ -41,8 +42,7 @@ class OpenTracingShimTest {
|
||||||
.isSameAs(textMapPropagator);
|
.isSameAs(textMapPropagator);
|
||||||
assertThat(tracerShim.propagation().getPropagator(Format.Builtin.HTTP_HEADERS))
|
assertThat(tracerShim.propagation().getPropagator(Format.Builtin.HTTP_HEADERS))
|
||||||
.isSameAs(textMapPropagator);
|
.isSameAs(textMapPropagator);
|
||||||
assertThat(tracerShim.tracer())
|
assertThat(tracerShim.tracer()).isEqualTo(sdk.get("opentracing-shim", OtelVersion.VERSION));
|
||||||
.isEqualTo(sdk.get("opentracing-shim", TracerShim.OPENTRACINGSHIM_VERSION));
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
|
|
@ -76,7 +76,6 @@ class OpenTracingShimTest {
|
||||||
.isSameAs(textMapPropagator);
|
.isSameAs(textMapPropagator);
|
||||||
assertThat(tracerShim.propagation().getPropagator(Format.Builtin.HTTP_HEADERS))
|
assertThat(tracerShim.propagation().getPropagator(Format.Builtin.HTTP_HEADERS))
|
||||||
.isSameAs(httpHeadersPropagator);
|
.isSameAs(httpHeadersPropagator);
|
||||||
assertThat(tracerShim.tracer())
|
assertThat(tracerShim.tracer()).isSameAs(sdk.get("opentracing-shim", OtelVersion.VERSION));
|
||||||
.isSameAs(sdk.get("opentracing-shim", TracerShim.OPENTRACINGSHIM_VERSION));
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue