parent
1ad203a666
commit
3b77cc4b2d
|
@ -16,8 +16,8 @@ plugins {
|
|||
val latestReleasedVersion: String by lazy {
|
||||
// hack to find the current released version of the project
|
||||
val temp: Configuration = configurations.create("tempConfig")
|
||||
// pick the agent, since it's always there.
|
||||
dependencies.add(temp.name, "io.opentelemetry.javaagent:opentelemetry-javaagent:latest.release")
|
||||
// pick the bom, since we don't use dependency substitution on it.
|
||||
dependencies.add(temp.name, "io.opentelemetry.instrumentation:opentelemetry-instrumentation-bom:latest.release")
|
||||
val moduleVersion = configurations["tempConfig"].resolvedConfiguration.firstLevelModuleDependencies.elementAt(0).moduleVersion
|
||||
|
||||
configurations.remove(temp)
|
||||
|
|
|
@ -412,6 +412,7 @@ configurations.configureEach {
|
|||
substitute(module("io.opentelemetry.javaagent:opentelemetry-agent-for-testing")).using(project(":testing:agent-for-testing"))
|
||||
substitute(module("io.opentelemetry.javaagent:opentelemetry-testing-common")).using(project(":testing-common"))
|
||||
substitute(module("io.opentelemetry.javaagent:opentelemetry-muzzle")).using(project(":muzzle"))
|
||||
substitute(module("io.opentelemetry.javaagent:opentelemetry-javaagent")).using(project(":javaagent"))
|
||||
}
|
||||
|
||||
// The above substitutions ensure dependencies managed by this BOM for external projects refer to this repo's projects here.
|
||||
|
@ -420,9 +421,3 @@ configurations.configureEach {
|
|||
exclude("io.opentelemetry.instrumentation", "opentelemetry-instrumentation-bom-alpha")
|
||||
}
|
||||
}
|
||||
|
||||
// Pin opentelemetry-semconv to last version where io.opentelemetry.semconv.trace.attributes.SemanticAttributes
|
||||
// isn't deprecated.
|
||||
configurations.configureEach {
|
||||
resolutionStrategy.force("io.opentelemetry:opentelemetry-semconv:1.29.0-alpha")
|
||||
}
|
||||
|
|
|
@ -47,6 +47,7 @@ val mockitoVersion = "4.11.0"
|
|||
val slf4jVersion = "2.0.9"
|
||||
|
||||
val CORE_DEPENDENCIES = listOf(
|
||||
"io.opentelemetry.semconv:opentelemetry-semconv:1.21.0-alpha",
|
||||
"com.google.auto.service:auto-service:${autoServiceVersion}",
|
||||
"com.google.auto.service:auto-service-annotations:${autoServiceVersion}",
|
||||
"com.google.auto.value:auto-value:${autoValueVersion}",
|
||||
|
|
|
@ -7,8 +7,8 @@ package io.opentelemetry.javaagent.instrumentation.otelannotations;
|
|||
|
||||
import static io.opentelemetry.api.common.AttributeKey.booleanKey;
|
||||
import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.equalTo;
|
||||
import static io.opentelemetry.semconv.trace.attributes.SemanticAttributes.CODE_FUNCTION;
|
||||
import static io.opentelemetry.semconv.trace.attributes.SemanticAttributes.CODE_NAMESPACE;
|
||||
import static io.opentelemetry.semconv.SemanticAttributes.CODE_FUNCTION;
|
||||
import static io.opentelemetry.semconv.SemanticAttributes.CODE_NAMESPACE;
|
||||
import static org.assertj.core.api.Assertions.assertThat;
|
||||
import static org.assertj.core.api.Assertions.catchThrowable;
|
||||
|
||||
|
|
|
@ -11,7 +11,7 @@ dependencies {
|
|||
implementation(project(":instrumentation-api"))
|
||||
|
||||
api("io.opentelemetry:opentelemetry-api")
|
||||
api("io.opentelemetry:opentelemetry-semconv")
|
||||
api("io.opentelemetry.semconv:opentelemetry-semconv")
|
||||
|
||||
compileOnly("com.google.auto.value:auto-value-annotations")
|
||||
annotationProcessor("com.google.auto.value:auto-value")
|
||||
|
|
|
@ -11,7 +11,7 @@ plugins {
|
|||
group = "io.opentelemetry.instrumentation"
|
||||
|
||||
dependencies {
|
||||
api("io.opentelemetry:opentelemetry-semconv")
|
||||
api("io.opentelemetry.semconv:opentelemetry-semconv")
|
||||
api(project(":instrumentation-api"))
|
||||
implementation("io.opentelemetry:opentelemetry-extension-incubator")
|
||||
|
||||
|
|
|
@ -10,7 +10,7 @@ import static io.opentelemetry.instrumentation.api.internal.AttributesExtractorU
|
|||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.context.Context;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import javax.annotation.Nullable;
|
||||
|
||||
/**
|
||||
|
|
|
@ -10,7 +10,7 @@ import static io.opentelemetry.instrumentation.api.internal.AttributesExtractorU
|
|||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.context.Context;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
|
||||
/**
|
||||
* Extractor of <a
|
||||
|
|
|
@ -12,7 +12,7 @@ import io.opentelemetry.context.Context;
|
|||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.instrumentation.api.internal.SpanKey;
|
||||
import io.opentelemetry.instrumentation.api.internal.SpanKeyProvider;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import javax.annotation.Nullable;
|
||||
|
||||
abstract class DbClientCommonAttributesExtractor<
|
||||
|
|
|
@ -13,7 +13,7 @@ import io.opentelemetry.context.Context;
|
|||
import io.opentelemetry.instrumentation.api.db.SqlStatementInfo;
|
||||
import io.opentelemetry.instrumentation.api.db.SqlStatementSanitizer;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
|
||||
/**
|
||||
* Extractor of <a
|
||||
|
|
|
@ -11,7 +11,7 @@ import com.google.errorprone.annotations.CanIgnoreReturnValue;
|
|||
import io.opentelemetry.api.common.AttributeKey;
|
||||
import io.opentelemetry.instrumentation.api.db.SqlStatementSanitizer;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
|
||||
/** A builder of {@link SqlClientAttributesExtractor}. */
|
||||
public final class SqlClientAttributesExtractorBuilder<REQUEST, RESPONSE> {
|
||||
|
|
|
@ -17,7 +17,7 @@ import io.opentelemetry.instrumentation.api.instrumenter.url.internal.UrlAttribu
|
|||
import io.opentelemetry.instrumentation.api.internal.SemconvStability;
|
||||
import io.opentelemetry.instrumentation.api.internal.SpanKey;
|
||||
import io.opentelemetry.instrumentation.api.internal.SpanKeyProvider;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.function.ToIntFunction;
|
||||
import javax.annotation.Nullable;
|
||||
|
||||
|
@ -101,6 +101,7 @@ public final class HttpClientAttributesExtractor<REQUEST, RESPONSE>
|
|||
}
|
||||
|
||||
@Override
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
public void onStart(AttributesBuilder attributes, Context parentContext, REQUEST request) {
|
||||
super.onStart(attributes, parentContext, request);
|
||||
|
||||
|
|
|
@ -16,7 +16,7 @@ import io.opentelemetry.context.Context;
|
|||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.http.internal.HttpAttributes;
|
||||
import io.opentelemetry.instrumentation.api.internal.SemconvStability;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.HashSet;
|
||||
import java.util.List;
|
||||
import java.util.Set;
|
||||
|
@ -48,6 +48,7 @@ abstract class HttpCommonAttributesExtractor<
|
|||
}
|
||||
|
||||
@Override
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
public void onStart(AttributesBuilder attributes, Context parentContext, REQUEST request) {
|
||||
String method = getter.getHttpRequestMethod(request);
|
||||
if (SemconvStability.emitStableHttpSemconv()) {
|
||||
|
@ -72,6 +73,7 @@ abstract class HttpCommonAttributesExtractor<
|
|||
}
|
||||
|
||||
@Override
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
public void onEnd(
|
||||
AttributesBuilder attributes,
|
||||
Context context,
|
||||
|
|
|
@ -9,16 +9,18 @@ import io.opentelemetry.api.common.AttributeKey;
|
|||
import io.opentelemetry.api.common.Attributes;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.http.internal.HttpAttributes;
|
||||
import io.opentelemetry.instrumentation.api.internal.SemconvStability;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import javax.annotation.Nullable;
|
||||
|
||||
final class HttpMessageBodySizeUtil {
|
||||
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
private static final AttributeKey<Long> HTTP_REQUEST_BODY_SIZE =
|
||||
SemconvStability.emitOldHttpSemconv()
|
||||
? SemanticAttributes.HTTP_REQUEST_CONTENT_LENGTH
|
||||
: HttpAttributes.HTTP_REQUEST_BODY_SIZE;
|
||||
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
private static final AttributeKey<Long> HTTP_RESPONSE_BODY_SIZE =
|
||||
SemconvStability.emitOldHttpSemconv()
|
||||
? SemanticAttributes.HTTP_RESPONSE_CONTENT_LENGTH
|
||||
|
|
|
@ -16,7 +16,7 @@ import io.opentelemetry.extension.incubator.metrics.ExtendedLongUpDownCounterBui
|
|||
import io.opentelemetry.instrumentation.api.instrumenter.http.internal.HttpAttributes;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.network.internal.NetworkAttributes;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.url.internal.UrlAttributes;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
|
||||
final class HttpMetricsAdvice {
|
||||
|
||||
|
@ -38,6 +38,7 @@ final class HttpMetricsAdvice {
|
|||
NetworkAttributes.SERVER_SOCKET_ADDRESS)));
|
||||
}
|
||||
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
static void applyOldClientDurationAdvice(DoubleHistogramBuilder builder) {
|
||||
if (!(builder instanceof ExtendedDoubleHistogramBuilder)) {
|
||||
return;
|
||||
|
@ -56,6 +57,7 @@ final class HttpMetricsAdvice {
|
|||
SemanticAttributes.NET_SOCK_PEER_ADDR)));
|
||||
}
|
||||
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
static void applyClientRequestSizeAdvice(LongHistogramBuilder builder) {
|
||||
if (!(builder instanceof ExtendedLongHistogramBuilder)) {
|
||||
return;
|
||||
|
@ -100,6 +102,7 @@ final class HttpMetricsAdvice {
|
|||
UrlAttributes.URL_SCHEME)));
|
||||
}
|
||||
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
static void applyOldServerDurationAdvice(DoubleHistogramBuilder builder) {
|
||||
if (!(builder instanceof ExtendedDoubleHistogramBuilder)) {
|
||||
return;
|
||||
|
@ -119,6 +122,7 @@ final class HttpMetricsAdvice {
|
|||
SemanticAttributes.NET_PROTOCOL_VERSION)));
|
||||
}
|
||||
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
static void applyServerRequestSizeAdvice(LongHistogramBuilder builder) {
|
||||
if (!(builder instanceof ExtendedLongHistogramBuilder)) {
|
||||
return;
|
||||
|
@ -146,6 +150,7 @@ final class HttpMetricsAdvice {
|
|||
SemanticAttributes.NET_PROTOCOL_VERSION)));
|
||||
}
|
||||
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
static void applyServerActiveRequestsAdvice(LongUpDownCounterBuilder builder) {
|
||||
if (!(builder instanceof ExtendedLongUpDownCounterBuilder)) {
|
||||
return;
|
||||
|
|
|
@ -17,7 +17,7 @@ import io.opentelemetry.instrumentation.api.instrumenter.network.internal.Intern
|
|||
import io.opentelemetry.instrumentation.api.instrumenter.url.internal.InternalUrlAttributesExtractor;
|
||||
import io.opentelemetry.instrumentation.api.internal.SpanKey;
|
||||
import io.opentelemetry.instrumentation.api.internal.SpanKeyProvider;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.function.Function;
|
||||
import javax.annotation.Nullable;
|
||||
|
||||
|
|
|
@ -11,7 +11,7 @@ import io.opentelemetry.instrumentation.api.instrumenter.ContextCustomizer;
|
|||
import io.opentelemetry.instrumentation.api.instrumenter.Instrumenter;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.LocalRootSpan;
|
||||
import io.opentelemetry.instrumentation.api.internal.HttpRouteState;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import javax.annotation.Nullable;
|
||||
|
||||
/**
|
||||
|
|
|
@ -16,7 +16,7 @@ import io.opentelemetry.context.Context;
|
|||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.instrumentation.api.internal.SpanKey;
|
||||
import io.opentelemetry.instrumentation.api.internal.SpanKeyProvider;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.List;
|
||||
import javax.annotation.Nullable;
|
||||
|
||||
|
|
|
@ -10,7 +10,7 @@ import io.opentelemetry.context.Context;
|
|||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.network.ServerAttributesGetter;
|
||||
import io.opentelemetry.instrumentation.api.internal.SemconvStability;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.Map;
|
||||
import javax.annotation.Nullable;
|
||||
|
||||
|
|
|
@ -10,7 +10,7 @@ import static io.opentelemetry.instrumentation.api.internal.AttributesExtractorU
|
|||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.network.internal.AddressAndPort;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.network.internal.FallbackAddressPortExtractor;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import javax.annotation.Nullable;
|
||||
|
||||
/**
|
||||
|
|
|
@ -10,7 +10,7 @@ import static io.opentelemetry.instrumentation.api.internal.AttributesExtractorU
|
|||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.network.internal.AddressAndPort;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.network.internal.FallbackAddressPortExtractor;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
|
||||
/**
|
||||
* This class is internal and is hence not for public use. Its APIs are unstable and can change at
|
||||
|
|
|
@ -9,7 +9,7 @@ import static io.opentelemetry.instrumentation.api.internal.AttributesExtractorU
|
|||
|
||||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.network.ClientAttributesGetter;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import javax.annotation.Nullable;
|
||||
|
||||
/**
|
||||
|
@ -34,6 +34,7 @@ public final class InternalClientAttributesExtractor<REQUEST, RESPONSE> {
|
|||
this.emitOldHttpAttributes = emitOldHttpAttributes;
|
||||
}
|
||||
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
public void onStart(AttributesBuilder attributes, REQUEST request) {
|
||||
AddressAndPort clientAddressAndPort = extractClientAddressAndPort(request);
|
||||
|
||||
|
@ -48,6 +49,7 @@ public final class InternalClientAttributesExtractor<REQUEST, RESPONSE> {
|
|||
}
|
||||
}
|
||||
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
public void onEnd(AttributesBuilder attributes, REQUEST request, @Nullable RESPONSE response) {
|
||||
AddressAndPort clientAddressAndPort = extractClientAddressAndPort(request);
|
||||
String clientSocketAddress = getter.getClientSocketAddress(request, response);
|
||||
|
|
|
@ -9,7 +9,7 @@ import static io.opentelemetry.instrumentation.api.internal.AttributesExtractorU
|
|||
|
||||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.network.NetworkAttributesGetter;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.Locale;
|
||||
import javax.annotation.Nullable;
|
||||
|
||||
|
@ -35,6 +35,7 @@ public final class InternalNetworkAttributesExtractor<REQUEST, RESPONSE> {
|
|||
this.emitOldHttpAttributes = emitOldHttpAttributes;
|
||||
}
|
||||
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
public void onEnd(AttributesBuilder attributes, REQUEST request, @Nullable RESPONSE response) {
|
||||
String protocolName = lowercase(getter.getNetworkProtocolName(request, response));
|
||||
String protocolVersion = lowercase(getter.getNetworkProtocolVersion(request, response));
|
||||
|
|
|
@ -10,7 +10,7 @@ import static io.opentelemetry.instrumentation.api.internal.AttributesExtractorU
|
|||
import io.opentelemetry.api.common.AttributeKey;
|
||||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.network.ServerAttributesGetter;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.function.BiPredicate;
|
||||
import javax.annotation.Nullable;
|
||||
|
||||
|
@ -117,7 +117,10 @@ public final class InternalServerAttributesExtractor<REQUEST, RESPONSE> {
|
|||
* This class is internal and is hence not for public use. Its APIs are unstable and can change at
|
||||
* any time.
|
||||
*/
|
||||
@SuppressWarnings("ImmutableEnumChecker")
|
||||
@SuppressWarnings({
|
||||
"ImmutableEnumChecker",
|
||||
"deprecation"
|
||||
}) // until old http semconv are dropped in 2.0
|
||||
public enum Mode {
|
||||
PEER(
|
||||
SemanticAttributes.NET_PEER_NAME,
|
||||
|
|
|
@ -10,7 +10,7 @@ import static io.opentelemetry.instrumentation.api.internal.AttributesExtractorU
|
|||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.context.Context;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import javax.annotation.Nullable;
|
||||
|
||||
abstract class RpcCommonAttributesExtractor<REQUEST, RESPONSE>
|
||||
|
|
|
@ -10,12 +10,13 @@ import io.opentelemetry.api.metrics.DoubleHistogramBuilder;
|
|||
import io.opentelemetry.extension.incubator.metrics.ExtendedDoubleHistogramBuilder;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.network.internal.NetworkAttributes;
|
||||
import io.opentelemetry.instrumentation.api.internal.SemconvStability;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
|
||||
final class RpcMetricsAdvice {
|
||||
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
static void applyClientDurationAdvice(DoubleHistogramBuilder builder) {
|
||||
if (!(builder instanceof ExtendedDoubleHistogramBuilder)) {
|
||||
return;
|
||||
|
@ -47,6 +48,7 @@ final class RpcMetricsAdvice {
|
|||
.setAdvice(advice -> advice.setAttributes(attributes));
|
||||
}
|
||||
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
static void applyServerDurationAdvice(DoubleHistogramBuilder builder) {
|
||||
if (!(builder instanceof ExtendedDoubleHistogramBuilder)) {
|
||||
return;
|
||||
|
|
|
@ -9,7 +9,7 @@ import static io.opentelemetry.instrumentation.api.internal.AttributesExtractorU
|
|||
|
||||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.url.UrlAttributesGetter;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.function.Function;
|
||||
import javax.annotation.Nullable;
|
||||
|
||||
|
@ -35,6 +35,7 @@ public final class InternalUrlAttributesExtractor<REQUEST> {
|
|||
this.emitOldHttpAttributes = emitOldHttpAttributes;
|
||||
}
|
||||
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
public void onStart(AttributesBuilder attributes, REQUEST request) {
|
||||
String urlScheme = getUrlScheme(request);
|
||||
String urlPath = getter.getUrlPath(request);
|
||||
|
|
|
@ -12,7 +12,7 @@ import io.opentelemetry.api.common.Attributes;
|
|||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.context.Context;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.Collections;
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
|
|
|
@ -12,7 +12,7 @@ import io.opentelemetry.api.common.Attributes;
|
|||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.context.Context;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.Collections;
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
|
|
|
@ -12,7 +12,7 @@ import io.opentelemetry.api.common.Attributes;
|
|||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.context.Context;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.Collections;
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
|
|
|
@ -17,7 +17,7 @@ import io.opentelemetry.api.common.Attributes;
|
|||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.context.Context;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
@ -31,6 +31,7 @@ import org.junit.jupiter.params.provider.Arguments;
|
|||
import org.junit.jupiter.params.provider.ArgumentsProvider;
|
||||
import org.junit.jupiter.params.provider.ArgumentsSource;
|
||||
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
class HttpClientAttributesExtractorTest {
|
||||
|
||||
static class TestHttpClientAttributesGetter
|
||||
|
|
|
@ -17,13 +17,14 @@ import io.opentelemetry.context.Context;
|
|||
import io.opentelemetry.instrumentation.api.instrumenter.OperationListener;
|
||||
import io.opentelemetry.sdk.metrics.SdkMeterProvider;
|
||||
import io.opentelemetry.sdk.testing.exporter.InMemoryMetricReader;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
class HttpClientExperimentalMetricsTest {
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
void collectsMetrics() {
|
||||
InMemoryMetricReader metricReader = InMemoryMetricReader.create();
|
||||
SdkMeterProvider meterProvider =
|
||||
|
|
|
@ -18,7 +18,7 @@ import io.opentelemetry.instrumentation.api.instrumenter.OperationListener;
|
|||
import io.opentelemetry.sdk.metrics.SdkMeterProvider;
|
||||
import io.opentelemetry.sdk.metrics.internal.aggregator.ExplicitBucketHistogramUtils;
|
||||
import io.opentelemetry.sdk.testing.exporter.InMemoryMetricReader;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
|
@ -30,6 +30,7 @@ class HttpClientMetricsTest {
|
|||
.toArray();
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
void collectsMetrics() {
|
||||
InMemoryMetricReader metricReader = InMemoryMetricReader.create();
|
||||
SdkMeterProvider meterProvider =
|
||||
|
|
|
@ -17,7 +17,7 @@ import io.opentelemetry.api.common.Attributes;
|
|||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.context.Context;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
@ -31,6 +31,7 @@ import org.junit.jupiter.params.provider.Arguments;
|
|||
import org.junit.jupiter.params.provider.ArgumentsProvider;
|
||||
import org.junit.jupiter.params.provider.ArgumentsSource;
|
||||
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
class HttpServerAttributesExtractorTest {
|
||||
|
||||
static class TestHttpServerAttributesGetter
|
||||
|
|
|
@ -7,7 +7,7 @@ package io.opentelemetry.instrumentation.api.instrumenter.http;
|
|||
|
||||
import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.assertThat;
|
||||
import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.equalTo;
|
||||
import static io.opentelemetry.semconv.trace.attributes.SemanticAttributes.NetTransportValues.IP_TCP;
|
||||
import static io.opentelemetry.semconv.SemanticAttributes.NetTransportValues.IP_TCP;
|
||||
|
||||
import io.opentelemetry.api.common.Attributes;
|
||||
import io.opentelemetry.api.trace.Span;
|
||||
|
@ -18,13 +18,14 @@ import io.opentelemetry.context.Context;
|
|||
import io.opentelemetry.instrumentation.api.instrumenter.OperationListener;
|
||||
import io.opentelemetry.sdk.metrics.SdkMeterProvider;
|
||||
import io.opentelemetry.sdk.testing.exporter.InMemoryMetricReader;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
class HttpServerExperimentalMetricsTest {
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
void collectsMetrics() {
|
||||
InMemoryMetricReader metricReader = InMemoryMetricReader.create();
|
||||
SdkMeterProvider meterProvider =
|
||||
|
|
|
@ -7,7 +7,7 @@ package io.opentelemetry.instrumentation.api.instrumenter.http;
|
|||
|
||||
import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.assertThat;
|
||||
import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.equalTo;
|
||||
import static io.opentelemetry.semconv.trace.attributes.SemanticAttributes.NetTransportValues.IP_TCP;
|
||||
import static io.opentelemetry.semconv.SemanticAttributes.NetTransportValues.IP_TCP;
|
||||
|
||||
import io.opentelemetry.api.common.Attributes;
|
||||
import io.opentelemetry.api.trace.Span;
|
||||
|
@ -19,10 +19,11 @@ import io.opentelemetry.instrumentation.api.instrumenter.OperationListener;
|
|||
import io.opentelemetry.sdk.metrics.SdkMeterProvider;
|
||||
import io.opentelemetry.sdk.metrics.internal.aggregator.ExplicitBucketHistogramUtils;
|
||||
import io.opentelemetry.sdk.testing.exporter.InMemoryMetricReader;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
class HttpServerMetricsTest {
|
||||
|
||||
static final double[] DEFAULT_BUCKETS =
|
||||
|
|
|
@ -13,7 +13,7 @@ import io.opentelemetry.api.common.Attributes;
|
|||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.context.Context;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Collections;
|
||||
import java.util.HashMap;
|
||||
|
|
|
@ -12,7 +12,7 @@ import io.opentelemetry.api.common.Attributes;
|
|||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.context.Context;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.net.Inet4Address;
|
||||
import java.net.InetSocketAddress;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
|
|
@ -12,7 +12,7 @@ import io.opentelemetry.api.common.Attributes;
|
|||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.context.Context;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.net.Inet4Address;
|
||||
import java.net.InetSocketAddress;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
|
|
@ -6,7 +6,7 @@
|
|||
package io.opentelemetry.instrumentation.api.instrumenter.net;
|
||||
|
||||
import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.assertThat;
|
||||
import static io.opentelemetry.semconv.trace.attributes.SemanticAttributes.NetTransportValues.IP_TCP;
|
||||
import static io.opentelemetry.semconv.SemanticAttributes.NetTransportValues.IP_TCP;
|
||||
import static java.util.Collections.emptyMap;
|
||||
import static org.assertj.core.api.Assertions.entry;
|
||||
|
||||
|
@ -14,7 +14,7 @@ import io.opentelemetry.api.common.Attributes;
|
|||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.context.Context;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
import javax.annotation.Nullable;
|
||||
|
|
|
@ -6,7 +6,7 @@
|
|||
package io.opentelemetry.instrumentation.api.instrumenter.net;
|
||||
|
||||
import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.assertThat;
|
||||
import static io.opentelemetry.semconv.trace.attributes.SemanticAttributes.NetTransportValues.IP_TCP;
|
||||
import static io.opentelemetry.semconv.SemanticAttributes.NetTransportValues.IP_TCP;
|
||||
import static java.util.Collections.emptyMap;
|
||||
import static org.assertj.core.api.Assertions.entry;
|
||||
|
||||
|
@ -14,7 +14,7 @@ import io.opentelemetry.api.common.Attributes;
|
|||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.context.Context;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
import javax.annotation.Nullable;
|
||||
|
|
|
@ -19,7 +19,7 @@ import io.opentelemetry.api.common.AttributesBuilder;
|
|||
import io.opentelemetry.context.Context;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.network.ServerAttributesGetter;
|
||||
import io.opentelemetry.instrumentation.api.internal.SemconvStability;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
import org.junit.jupiter.api.Assumptions;
|
||||
|
|
|
@ -13,12 +13,13 @@ import io.opentelemetry.api.common.Attributes;
|
|||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.context.Context;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
import javax.annotation.Nullable;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
class ClientAttributesExtractorOldSemconvTest {
|
||||
|
||||
static class TestClientAttributesGetter
|
||||
|
|
|
@ -13,12 +13,13 @@ import io.opentelemetry.api.common.Attributes;
|
|||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.context.Context;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
import javax.annotation.Nullable;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
class NetworkAttributesExtractorOldSemconvTest {
|
||||
|
||||
static class TestNetworkAttributesGetter
|
||||
|
|
|
@ -13,12 +13,13 @@ import io.opentelemetry.api.common.Attributes;
|
|||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.context.Context;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
import javax.annotation.Nullable;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
class ServerAttributesExtractorOldSemconvTest {
|
||||
|
||||
static class TestServerAttributesGetter
|
||||
|
|
|
@ -12,7 +12,7 @@ import io.opentelemetry.api.common.Attributes;
|
|||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.context.Context;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
|
|
@ -17,13 +17,14 @@ import io.opentelemetry.context.Context;
|
|||
import io.opentelemetry.instrumentation.api.instrumenter.OperationListener;
|
||||
import io.opentelemetry.sdk.metrics.SdkMeterProvider;
|
||||
import io.opentelemetry.sdk.testing.exporter.InMemoryMetricReader;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
class RpcClientMetricsTest {
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
void collectsMetrics() {
|
||||
InMemoryMetricReader metricReader = InMemoryMetricReader.createDelta();
|
||||
SdkMeterProvider meterProvider =
|
||||
|
|
|
@ -17,13 +17,14 @@ import io.opentelemetry.context.Context;
|
|||
import io.opentelemetry.instrumentation.api.instrumenter.OperationListener;
|
||||
import io.opentelemetry.sdk.metrics.SdkMeterProvider;
|
||||
import io.opentelemetry.sdk.testing.exporter.InMemoryMetricReader;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
class RpcServerMetricsTest {
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
void collectsMetrics() {
|
||||
InMemoryMetricReader metricReader = InMemoryMetricReader.createDelta();
|
||||
SdkMeterProvider meterProvider =
|
||||
|
|
|
@ -19,7 +19,7 @@ import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
|||
import io.opentelemetry.instrumentation.api.instrumenter.http.internal.HttpAttributes;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.network.internal.NetworkAttributes;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.url.internal.UrlAttributes;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
@ -104,6 +104,7 @@ class HttpClientAttributesExtractorBothSemconvTest {
|
|||
}
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
void normal() {
|
||||
Map<String, String> request = new HashMap<>();
|
||||
request.put("method", "POST");
|
||||
|
|
|
@ -19,7 +19,7 @@ import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
|||
import io.opentelemetry.instrumentation.api.instrumenter.http.internal.HttpAttributes;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.network.internal.NetworkAttributes;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.url.internal.UrlAttributes;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
@ -121,6 +121,7 @@ class HttpServerAttributesExtractorBothSemconvTest {
|
|||
}
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
void normal() {
|
||||
Map<String, Object> request = new HashMap<>();
|
||||
request.put("method", "POST");
|
||||
|
|
|
@ -6,7 +6,7 @@
|
|||
package io.opentelemetry.instrumentation.api.instrumenter.net;
|
||||
|
||||
import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.assertThat;
|
||||
import static io.opentelemetry.semconv.trace.attributes.SemanticAttributes.NetTransportValues.IP_TCP;
|
||||
import static io.opentelemetry.semconv.SemanticAttributes.NetTransportValues.IP_TCP;
|
||||
import static org.assertj.core.api.Assertions.entry;
|
||||
|
||||
import io.opentelemetry.api.common.Attributes;
|
||||
|
@ -14,7 +14,7 @@ import io.opentelemetry.api.common.AttributesBuilder;
|
|||
import io.opentelemetry.context.Context;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.network.internal.NetworkAttributes;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
import javax.annotation.Nullable;
|
||||
|
|
|
@ -6,7 +6,7 @@
|
|||
package io.opentelemetry.instrumentation.api.instrumenter.net;
|
||||
|
||||
import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.assertThat;
|
||||
import static io.opentelemetry.semconv.trace.attributes.SemanticAttributes.NetTransportValues.IP_TCP;
|
||||
import static io.opentelemetry.semconv.SemanticAttributes.NetTransportValues.IP_TCP;
|
||||
import static org.assertj.core.api.Assertions.entry;
|
||||
|
||||
import io.opentelemetry.api.common.Attributes;
|
||||
|
@ -14,7 +14,7 @@ import io.opentelemetry.api.common.AttributesBuilder;
|
|||
import io.opentelemetry.context.Context;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.network.internal.NetworkAttributes;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
import javax.annotation.Nullable;
|
||||
|
|
|
@ -22,7 +22,7 @@ import io.opentelemetry.instrumentation.api.instrumenter.http.internal.HttpAttri
|
|||
import io.opentelemetry.instrumentation.api.instrumenter.network.internal.NetworkAttributes;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.url.internal.UrlAttributes;
|
||||
import io.opentelemetry.instrumentation.api.internal.HttpConstants;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.HashMap;
|
||||
import java.util.HashSet;
|
||||
import java.util.List;
|
||||
|
|
|
@ -22,7 +22,7 @@ import io.opentelemetry.instrumentation.api.instrumenter.http.internal.HttpAttri
|
|||
import io.opentelemetry.instrumentation.api.instrumenter.network.internal.NetworkAttributes;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.url.internal.UrlAttributes;
|
||||
import io.opentelemetry.instrumentation.api.internal.HttpConstants;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.HashMap;
|
||||
import java.util.HashSet;
|
||||
import java.util.List;
|
||||
|
|
|
@ -20,7 +20,7 @@ import io.opentelemetry.instrumentation.api.instrumenter.network.internal.Networ
|
|||
import io.opentelemetry.instrumentation.api.instrumenter.url.internal.UrlAttributes;
|
||||
import io.opentelemetry.sdk.metrics.SdkMeterProvider;
|
||||
import io.opentelemetry.sdk.testing.exporter.InMemoryMetricReader;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
|
|
|
@ -6,7 +6,7 @@
|
|||
package io.opentelemetry.instrumentation.api.instrumenter.net;
|
||||
|
||||
import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.assertThat;
|
||||
import static io.opentelemetry.semconv.trace.attributes.SemanticAttributes.NetTransportValues.IP_TCP;
|
||||
import static io.opentelemetry.semconv.SemanticAttributes.NetTransportValues.IP_TCP;
|
||||
import static org.assertj.core.api.Assertions.entry;
|
||||
|
||||
import io.opentelemetry.api.common.Attributes;
|
||||
|
|
|
@ -6,7 +6,7 @@
|
|||
package io.opentelemetry.instrumentation.api.instrumenter.net;
|
||||
|
||||
import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.assertThat;
|
||||
import static io.opentelemetry.semconv.trace.attributes.SemanticAttributes.NetTransportValues.IP_TCP;
|
||||
import static io.opentelemetry.semconv.SemanticAttributes.NetTransportValues.IP_TCP;
|
||||
import static org.assertj.core.api.Assertions.entry;
|
||||
|
||||
import io.opentelemetry.api.common.Attributes;
|
||||
|
|
|
@ -17,7 +17,7 @@ import io.opentelemetry.instrumentation.api.instrumenter.network.ServerAttribute
|
|||
import io.opentelemetry.instrumentation.api.instrumenter.rpc.RpcClientAttributesExtractor;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.rpc.RpcServerAttributesExtractor;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.rpc.RpcSpanNameExtractor;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import javax.annotation.Nullable;
|
||||
|
|
|
@ -10,7 +10,7 @@ import io.opentelemetry.instrumentation.apachedubbo.v2_7.api.HelloService
|
|||
import io.opentelemetry.instrumentation.apachedubbo.v2_7.impl.HelloServiceImpl
|
||||
import io.opentelemetry.instrumentation.test.InstrumentationSpecification
|
||||
import io.opentelemetry.instrumentation.test.utils.PortUtils
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes
|
||||
import io.opentelemetry.semconv.SemanticAttributes
|
||||
import org.apache.dubbo.common.utils.NetUtils
|
||||
import org.apache.dubbo.config.ApplicationConfig
|
||||
import org.apache.dubbo.config.ProtocolConfig
|
||||
|
|
|
@ -12,7 +12,7 @@ import io.opentelemetry.instrumentation.apachedubbo.v2_7.impl.HelloServiceImpl
|
|||
import io.opentelemetry.instrumentation.apachedubbo.v2_7.impl.MiddleServiceImpl
|
||||
import io.opentelemetry.instrumentation.test.InstrumentationSpecification
|
||||
import io.opentelemetry.instrumentation.test.utils.PortUtils
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes
|
||||
import io.opentelemetry.semconv.SemanticAttributes
|
||||
import org.apache.dubbo.common.utils.NetUtils
|
||||
import org.apache.dubbo.config.ApplicationConfig
|
||||
import org.apache.dubbo.config.ProtocolConfig
|
||||
|
|
|
@ -6,7 +6,7 @@
|
|||
import io.opentelemetry.api.common.AttributeKey
|
||||
import io.opentelemetry.instrumentation.test.AgentTestTrait
|
||||
import io.opentelemetry.instrumentation.test.base.HttpClientTest
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes
|
||||
import io.opentelemetry.semconv.SemanticAttributes
|
||||
import org.apache.commons.httpclient.HttpClient
|
||||
import org.apache.commons.httpclient.HttpConnectionManager
|
||||
import org.apache.commons.httpclient.HttpMethod
|
||||
|
|
|
@ -10,7 +10,7 @@ import io.opentelemetry.instrumentation.api.internal.SemconvStability;
|
|||
import io.opentelemetry.instrumentation.testing.junit.http.AbstractHttpClientTest;
|
||||
import io.opentelemetry.instrumentation.testing.junit.http.HttpClientResult;
|
||||
import io.opentelemetry.instrumentation.testing.junit.http.HttpClientTestOptions;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.net.URI;
|
||||
import java.time.Duration;
|
||||
import java.util.HashSet;
|
||||
|
@ -35,6 +35,7 @@ abstract class AbstractApacheHttpClientTest<T extends HttpRequest>
|
|||
optionsBuilder.setHttpAttributes(this::getHttpAttributes);
|
||||
}
|
||||
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
protected Set<AttributeKey<?>> getHttpAttributes(URI uri) {
|
||||
Set<AttributeKey<?>> attributes = new HashSet<>(HttpClientTestOptions.DEFAULT_HTTP_ATTRIBUTES);
|
||||
if (SemconvStability.emitOldHttpSemconv()) {
|
||||
|
|
|
@ -28,7 +28,7 @@ import io.opentelemetry.instrumentation.api.instrumenter.http.HttpSpanNameExtrac
|
|||
import io.opentelemetry.instrumentation.api.instrumenter.http.HttpSpanNameExtractorBuilder;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.http.HttpSpanStatusExtractor;
|
||||
import io.opentelemetry.instrumentation.armeria.v1_3.internal.ArmeriaHttpClientAttributesGetter;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import java.util.Set;
|
||||
|
|
|
@ -19,7 +19,7 @@ import io.opentelemetry.instrumentation.testing.junit.http.AbstractHttpClientTes
|
|||
import io.opentelemetry.instrumentation.testing.junit.http.HttpClientInstrumentationExtension;
|
||||
import io.opentelemetry.instrumentation.testing.junit.http.HttpClientResult;
|
||||
import io.opentelemetry.instrumentation.testing.junit.http.HttpClientTestOptions;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.net.URI;
|
||||
import java.util.HashSet;
|
||||
import java.util.Map;
|
||||
|
@ -82,6 +82,7 @@ class AsyncHttpClientTest extends AbstractHttpClientTest<Request> {
|
|||
}
|
||||
|
||||
@Override
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
protected void configure(HttpClientTestOptions.Builder optionsBuilder) {
|
||||
optionsBuilder.disableTestRedirects();
|
||||
|
||||
|
|
|
@ -8,7 +8,7 @@ package io.opentelemetry.javaagent.instrumentation.asynchttpclient.v2_0;
|
|||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.context.Context;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import javax.annotation.Nullable;
|
||||
import org.asynchttpclient.Response;
|
||||
import org.asynchttpclient.netty.request.NettyRequest;
|
||||
|
|
|
@ -5,9 +5,9 @@
|
|||
|
||||
package io.opentelemetry.instrumentation.awslambdacore.v1_0.internal;
|
||||
|
||||
import static io.opentelemetry.semconv.resource.attributes.ResourceAttributes.CLOUD_ACCOUNT_ID;
|
||||
import static io.opentelemetry.semconv.resource.attributes.ResourceAttributes.CLOUD_RESOURCE_ID;
|
||||
import static io.opentelemetry.semconv.trace.attributes.SemanticAttributes.FAAS_INVOCATION_ID;
|
||||
import static io.opentelemetry.semconv.ResourceAttributes.CLOUD_ACCOUNT_ID;
|
||||
import static io.opentelemetry.semconv.ResourceAttributes.CLOUD_RESOURCE_ID;
|
||||
import static io.opentelemetry.semconv.SemanticAttributes.FAAS_INVOCATION_ID;
|
||||
|
||||
import com.amazonaws.services.lambda.runtime.Context;
|
||||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
|
|
|
@ -20,8 +20,8 @@ import io.opentelemetry.instrumentation.awslambdacore.v1_0.internal.WrappedLambd
|
|||
import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
|
||||
import io.opentelemetry.instrumentation.testing.junit.LibraryInstrumentationExtension;
|
||||
import io.opentelemetry.sdk.trace.data.StatusData;
|
||||
import io.opentelemetry.semconv.resource.attributes.ResourceAttributes;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.ResourceAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.io.BufferedWriter;
|
||||
import java.io.ByteArrayInputStream;
|
||||
import java.io.ByteArrayOutputStream;
|
||||
|
|
|
@ -17,8 +17,8 @@ import io.opentelemetry.instrumentation.awslambdacore.v1_0.internal.WrappedLambd
|
|||
import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
|
||||
import io.opentelemetry.instrumentation.testing.junit.LibraryInstrumentationExtension;
|
||||
import io.opentelemetry.sdk.trace.data.StatusData;
|
||||
import io.opentelemetry.semconv.resource.attributes.ResourceAttributes;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.ResourceAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.io.BufferedReader;
|
||||
import java.io.BufferedWriter;
|
||||
import java.io.ByteArrayInputStream;
|
||||
|
|
|
@ -17,7 +17,7 @@ import io.opentelemetry.api.common.Attributes;
|
|||
import io.opentelemetry.api.trace.SpanKind;
|
||||
import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
|
||||
import io.opentelemetry.sdk.trace.data.StatusData;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import org.junit.jupiter.api.AfterEach;
|
||||
import org.junit.jupiter.api.BeforeEach;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
|
|
@ -10,9 +10,9 @@ import static io.opentelemetry.instrumentation.api.internal.AttributesExtractorU
|
|||
import static io.opentelemetry.instrumentation.api.internal.HttpConstants._OTHER;
|
||||
import static io.opentelemetry.instrumentation.awslambdacore.v1_0.internal.MapUtils.emptyIfNull;
|
||||
import static io.opentelemetry.instrumentation.awslambdacore.v1_0.internal.MapUtils.lowercaseMap;
|
||||
import static io.opentelemetry.semconv.trace.attributes.SemanticAttributes.FAAS_TRIGGER;
|
||||
import static io.opentelemetry.semconv.trace.attributes.SemanticAttributes.HTTP_STATUS_CODE;
|
||||
import static io.opentelemetry.semconv.trace.attributes.SemanticAttributes.USER_AGENT_ORIGINAL;
|
||||
import static io.opentelemetry.semconv.SemanticAttributes.FAAS_TRIGGER;
|
||||
import static io.opentelemetry.semconv.SemanticAttributes.HTTP_STATUS_CODE;
|
||||
import static io.opentelemetry.semconv.SemanticAttributes.USER_AGENT_ORIGINAL;
|
||||
|
||||
import com.amazonaws.services.lambda.runtime.events.APIGatewayProxyRequestEvent;
|
||||
import com.amazonaws.services.lambda.runtime.events.APIGatewayProxyResponseEvent;
|
||||
|
@ -23,7 +23,7 @@ import io.opentelemetry.instrumentation.api.instrumenter.http.internal.HttpAttri
|
|||
import io.opentelemetry.instrumentation.api.instrumenter.url.internal.UrlAttributes;
|
||||
import io.opentelemetry.instrumentation.api.internal.SemconvStability;
|
||||
import io.opentelemetry.instrumentation.awslambdacore.v1_0.AwsLambdaRequest;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.io.UnsupportedEncodingException;
|
||||
import java.net.URLEncoder;
|
||||
import java.nio.charset.StandardCharsets;
|
||||
|
@ -49,6 +49,7 @@ final class ApiGatewayProxyAttributesExtractor
|
|||
}
|
||||
}
|
||||
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
void onRequest(AttributesBuilder attributes, APIGatewayProxyRequestEvent request) {
|
||||
String method = request.getHttpMethod();
|
||||
if (SemconvStability.emitStableHttpSemconv()) {
|
||||
|
@ -114,6 +115,7 @@ final class ApiGatewayProxyAttributesExtractor
|
|||
}
|
||||
|
||||
@Override
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
public void onEnd(
|
||||
AttributesBuilder attributes,
|
||||
Context context,
|
||||
|
|
|
@ -9,7 +9,7 @@ import com.amazonaws.services.lambda.runtime.events.SQSEvent;
|
|||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.context.Context;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import javax.annotation.Nullable;
|
||||
|
||||
class SqsEventAttributesExtractor implements AttributesExtractor<SQSEvent, Void> {
|
||||
|
|
|
@ -9,7 +9,7 @@ import com.amazonaws.services.lambda.runtime.events.SQSEvent.SQSMessage;
|
|||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.context.Context;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import javax.annotation.Nullable;
|
||||
|
||||
class SqsMessageAttributesExtractor implements AttributesExtractor<SQSMessage, Void> {
|
||||
|
|
|
@ -17,8 +17,8 @@ import io.opentelemetry.api.trace.SpanKind;
|
|||
import io.opentelemetry.instrumentation.awslambdacore.v1_0.internal.WrappedLambda;
|
||||
import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
|
||||
import io.opentelemetry.instrumentation.testing.junit.LibraryInstrumentationExtension;
|
||||
import io.opentelemetry.semconv.resource.attributes.ResourceAttributes;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.ResourceAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
import org.junit.jupiter.api.AfterEach;
|
||||
|
@ -34,6 +34,7 @@ import org.mockito.quality.Strictness;
|
|||
|
||||
@ExtendWith(MockitoExtension.class)
|
||||
@MockitoSettings(strictness = Strictness.LENIENT)
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
public class AwsLambdaApiGatewayWrapperTest {
|
||||
|
||||
@RegisterExtension
|
||||
|
|
|
@ -16,8 +16,8 @@ import io.opentelemetry.api.trace.SpanKind;
|
|||
import io.opentelemetry.instrumentation.awslambdacore.v1_0.internal.WrappedLambda;
|
||||
import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
|
||||
import io.opentelemetry.instrumentation.testing.junit.LibraryInstrumentationExtension;
|
||||
import io.opentelemetry.semconv.resource.attributes.ResourceAttributes;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.ResourceAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.lang.reflect.Constructor;
|
||||
import java.util.Collections;
|
||||
import org.junit.jupiter.api.AfterEach;
|
||||
|
|
|
@ -19,7 +19,7 @@ import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
|
|||
import io.opentelemetry.instrumentation.testing.junit.LibraryInstrumentationExtension;
|
||||
import io.opentelemetry.sdk.OpenTelemetrySdk;
|
||||
import io.opentelemetry.sdk.trace.data.LinkData;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.lang.reflect.Constructor;
|
||||
import java.util.Arrays;
|
||||
import java.util.Collections;
|
||||
|
|
|
@ -17,8 +17,8 @@ import io.opentelemetry.instrumentation.awslambdacore.v1_0.internal.WrappedLambd
|
|||
import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
|
||||
import io.opentelemetry.instrumentation.testing.junit.LibraryInstrumentationExtension;
|
||||
import io.opentelemetry.sdk.trace.data.StatusData;
|
||||
import io.opentelemetry.semconv.resource.attributes.ResourceAttributes;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.ResourceAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import org.junit.jupiter.api.AfterEach;
|
||||
import org.junit.jupiter.api.BeforeEach;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
|
|
@ -14,7 +14,7 @@ import com.amazonaws.services.lambda.runtime.RequestHandler;
|
|||
import com.amazonaws.services.lambda.runtime.events.SQSEvent;
|
||||
import io.opentelemetry.api.trace.SpanKind;
|
||||
import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.lang.reflect.Constructor;
|
||||
import java.util.Arrays;
|
||||
import java.util.Collections;
|
||||
|
|
|
@ -4,7 +4,7 @@
|
|||
*/
|
||||
|
||||
import io.opentelemetry.instrumentation.test.AgentInstrumentationSpecification
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes
|
||||
import io.opentelemetry.semconv.SemanticAttributes
|
||||
import spock.lang.Shared
|
||||
|
||||
import static io.opentelemetry.api.trace.SpanKind.CLIENT
|
||||
|
|
|
@ -4,7 +4,7 @@
|
|||
*/
|
||||
|
||||
import io.opentelemetry.instrumentation.test.AgentInstrumentationSpecification
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes
|
||||
import io.opentelemetry.semconv.SemanticAttributes
|
||||
import spock.lang.Shared
|
||||
|
||||
import static io.opentelemetry.api.trace.SpanKind.CLIENT
|
||||
|
|
|
@ -19,7 +19,7 @@ import io.opentelemetry.api.trace.Span
|
|||
import io.opentelemetry.api.trace.SpanKind
|
||||
import io.opentelemetry.instrumentation.awssdk.v1_11.AbstractAws1ClientTest
|
||||
import io.opentelemetry.instrumentation.test.AgentTestTrait
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes
|
||||
import io.opentelemetry.semconv.SemanticAttributes
|
||||
|
||||
import static io.opentelemetry.api.trace.StatusCode.ERROR
|
||||
|
||||
|
|
|
@ -24,7 +24,7 @@ import com.amazonaws.services.s3.AmazonS3Client
|
|||
import com.amazonaws.services.s3.S3ClientOptions
|
||||
import io.opentelemetry.api.trace.Span
|
||||
import io.opentelemetry.instrumentation.test.AgentInstrumentationSpecification
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes
|
||||
import io.opentelemetry.semconv.SemanticAttributes
|
||||
import io.opentelemetry.testing.internal.armeria.common.HttpResponse
|
||||
import io.opentelemetry.testing.internal.armeria.common.HttpStatus
|
||||
import io.opentelemetry.testing.internal.armeria.common.MediaType
|
||||
|
|
|
@ -29,7 +29,7 @@ import com.amazonaws.services.s3.AmazonS3Client
|
|||
import com.amazonaws.services.s3.AmazonS3ClientBuilder
|
||||
import io.opentelemetry.api.trace.Span
|
||||
import io.opentelemetry.instrumentation.test.InstrumentationSpecification
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes
|
||||
import io.opentelemetry.semconv.SemanticAttributes
|
||||
import io.opentelemetry.testing.internal.armeria.common.HttpResponse
|
||||
import io.opentelemetry.testing.internal.armeria.common.HttpStatus
|
||||
import io.opentelemetry.testing.internal.armeria.common.MediaType
|
||||
|
|
|
@ -14,7 +14,7 @@ import com.amazonaws.services.sqs.model.ReceiveMessageRequest
|
|||
import com.amazonaws.services.sqs.model.SendMessageRequest
|
||||
import io.opentelemetry.instrumentation.test.InstrumentationSpecification
|
||||
import io.opentelemetry.instrumentation.test.utils.PortUtils
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes
|
||||
import io.opentelemetry.semconv.SemanticAttributes
|
||||
import org.elasticmq.rest.sqs.SQSRestServerBuilder
|
||||
import spock.lang.Shared
|
||||
|
||||
|
|
|
@ -14,7 +14,7 @@ import io.opentelemetry.context.Scope;
|
|||
import io.opentelemetry.context.propagation.TextMapPropagator;
|
||||
import io.opentelemetry.contrib.awsxray.propagator.AwsXrayPropagator;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.Instrumenter;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.List;
|
||||
import javax.annotation.Nullable;
|
||||
import software.amazon.awssdk.auth.signer.AwsSignerExecutionAttribute;
|
||||
|
|
|
@ -7,7 +7,7 @@ package io.opentelemetry.instrumentation.awssdk.v2_2
|
|||
|
||||
import io.opentelemetry.instrumentation.api.internal.ConfigPropertiesUtil
|
||||
import io.opentelemetry.instrumentation.test.InstrumentationSpecification
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes
|
||||
import io.opentelemetry.semconv.SemanticAttributes
|
||||
import io.opentelemetry.testing.internal.armeria.common.HttpResponse
|
||||
import io.opentelemetry.testing.internal.armeria.common.HttpStatus
|
||||
import io.opentelemetry.testing.internal.armeria.common.MediaType
|
||||
|
|
|
@ -6,7 +6,7 @@
|
|||
package io.opentelemetry.instrumentation.awssdk.v2_2
|
||||
|
||||
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes
|
||||
import io.opentelemetry.semconv.SemanticAttributes
|
||||
import io.opentelemetry.testing.internal.armeria.common.HttpResponse
|
||||
import io.opentelemetry.testing.internal.armeria.common.HttpStatus
|
||||
import io.opentelemetry.testing.internal.armeria.common.MediaType
|
||||
|
|
|
@ -6,7 +6,7 @@
|
|||
package io.opentelemetry.instrumentation.awssdk.v2_2
|
||||
|
||||
import io.opentelemetry.instrumentation.test.InstrumentationSpecification
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes
|
||||
import io.opentelemetry.semconv.SemanticAttributes
|
||||
import org.elasticmq.rest.sqs.SQSRestServerBuilder
|
||||
import software.amazon.awssdk.auth.credentials.AwsBasicCredentials
|
||||
import software.amazon.awssdk.auth.credentials.StaticCredentialsProvider
|
||||
|
|
|
@ -6,7 +6,7 @@
|
|||
package io.opentelemetry.instrumentation.awssdk.v2_2;
|
||||
|
||||
import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.assertThat;
|
||||
import static io.opentelemetry.semconv.trace.attributes.SemanticAttributes.HTTP_URL;
|
||||
import static io.opentelemetry.semconv.SemanticAttributes.HTTP_URL;
|
||||
|
||||
import io.opentelemetry.api.trace.SpanKind;
|
||||
import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
|
||||
|
@ -55,6 +55,7 @@ public abstract class AbstractQueryProtocolModelTest {
|
|||
protected abstract InstrumentationExtension getTesting();
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
void testClientWithQueryProtocolModel() {
|
||||
server.enqueue(
|
||||
HttpResponse.of(
|
||||
|
|
|
@ -27,7 +27,7 @@ import io.opentelemetry.api.common.AttributesBuilder;
|
|||
import io.opentelemetry.instrumentation.api.db.SqlStatementSanitizer;
|
||||
import io.opentelemetry.javaagent.bootstrap.internal.CommonConfig;
|
||||
import io.opentelemetry.javaagent.instrumentation.apachecamel.CamelDirection;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.net.URI;
|
||||
import java.util.Map;
|
||||
import org.apache.camel.Endpoint;
|
||||
|
|
|
@ -6,7 +6,7 @@
|
|||
package io.opentelemetry.javaagent.instrumentation.apachecamel.decorators;
|
||||
|
||||
import io.opentelemetry.javaagent.instrumentation.apachecamel.SpanDecorator;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes.DbSystemValues;
|
||||
import io.opentelemetry.semconv.SemanticAttributes.DbSystemValues;
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
|
||||
|
|
|
@ -35,7 +35,7 @@ import io.opentelemetry.instrumentation.api.instrumenter.url.internal.UrlAttribu
|
|||
import io.opentelemetry.instrumentation.api.internal.SemconvStability;
|
||||
import io.opentelemetry.javaagent.bootstrap.internal.CommonConfig;
|
||||
import io.opentelemetry.javaagent.instrumentation.apachecamel.CamelDirection;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.net.MalformedURLException;
|
||||
import java.net.URL;
|
||||
import java.util.Set;
|
||||
|
@ -91,6 +91,7 @@ class HttpSpanDecorator extends BaseSpanDecorator {
|
|||
}
|
||||
|
||||
@Override
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
public void pre(
|
||||
AttributesBuilder attributes,
|
||||
Exchange exchange,
|
||||
|
@ -176,6 +177,7 @@ class HttpSpanDecorator extends BaseSpanDecorator {
|
|||
}
|
||||
|
||||
@Override
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
public void post(AttributesBuilder attributes, Exchange exchange, Endpoint endpoint) {
|
||||
super.post(attributes, exchange, endpoint);
|
||||
|
||||
|
|
|
@ -25,7 +25,7 @@ package io.opentelemetry.javaagent.instrumentation.apachecamel.decorators;
|
|||
|
||||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.javaagent.instrumentation.apachecamel.CamelDirection;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.util.Map;
|
||||
import org.apache.camel.Endpoint;
|
||||
import org.apache.camel.Exchange;
|
||||
|
@ -64,11 +64,7 @@ class KafkaSpanDecorator extends MessagingSpanDecorator {
|
|||
|
||||
Integer partition = exchange.getIn().getHeader(PARTITION, Integer.class);
|
||||
if (partition != null) {
|
||||
if (camelDirection == CamelDirection.OUTBOUND) {
|
||||
attributes.put(SemanticAttributes.MESSAGING_KAFKA_DESTINATION_PARTITION, partition);
|
||||
} else {
|
||||
attributes.put(SemanticAttributes.MESSAGING_KAFKA_SOURCE_PARTITION, partition);
|
||||
}
|
||||
attributes.put(SemanticAttributes.MESSAGING_KAFKA_DESTINATION_PARTITION, partition);
|
||||
}
|
||||
|
||||
if (CAPTURE_EXPERIMENTAL_SPAN_ATTRIBUTES) {
|
||||
|
|
|
@ -26,7 +26,7 @@ package io.opentelemetry.javaagent.instrumentation.apachecamel.decorators;
|
|||
import io.opentelemetry.api.common.AttributesBuilder;
|
||||
import io.opentelemetry.api.trace.SpanKind;
|
||||
import io.opentelemetry.javaagent.instrumentation.apachecamel.CamelDirection;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.net.URI;
|
||||
import java.util.Map;
|
||||
import org.apache.camel.Endpoint;
|
||||
|
|
|
@ -14,7 +14,7 @@ import io.opentelemetry.api.trace.SpanKind;
|
|||
import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
|
||||
import io.opentelemetry.instrumentation.testing.junit.http.AbstractHttpServerUsingTest;
|
||||
import io.opentelemetry.instrumentation.testing.junit.http.HttpServerInstrumentationExtension;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import org.apache.camel.CamelContext;
|
||||
import org.apache.camel.ProducerTemplate;
|
||||
import org.junit.jupiter.api.AfterAll;
|
||||
|
@ -61,6 +61,7 @@ class RestCamelTest extends AbstractHttpServerUsingTest<ConfigurableApplicationC
|
|||
}
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
void restComponentServerAndClientCallWithJettyBackend() {
|
||||
CamelContext camelContext = appContext.getBean(CamelContext.class);
|
||||
ProducerTemplate template = camelContext.createProducerTemplate();
|
||||
|
|
|
@ -13,7 +13,7 @@ import io.opentelemetry.api.trace.SpanKind;
|
|||
import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
|
||||
import io.opentelemetry.instrumentation.testing.junit.http.AbstractHttpServerUsingTest;
|
||||
import io.opentelemetry.instrumentation.testing.junit.http.HttpServerInstrumentationExtension;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import java.net.URI;
|
||||
import org.junit.jupiter.api.AfterAll;
|
||||
import org.junit.jupiter.api.BeforeAll;
|
||||
|
@ -56,6 +56,7 @@ class SingleServiceCamelTest extends AbstractHttpServerUsingTest<ConfigurableApp
|
|||
}
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
public void singleCamelServiceSpan() {
|
||||
URI requestUrl = address.resolve("/camelService");
|
||||
|
||||
|
|
|
@ -15,7 +15,7 @@ import io.opentelemetry.instrumentation.test.utils.PortUtils;
|
|||
import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
|
||||
import io.opentelemetry.instrumentation.testing.junit.http.AbstractHttpServerUsingTest;
|
||||
import io.opentelemetry.instrumentation.testing.junit.http.HttpServerInstrumentationExtension;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import org.apache.camel.CamelContext;
|
||||
import org.apache.camel.ProducerTemplate;
|
||||
import org.apache.camel.builder.RouteBuilder;
|
||||
|
@ -85,6 +85,7 @@ class TwoServicesWithDirectClientCamelTest
|
|||
}
|
||||
|
||||
@Test
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
void twoCamelServiceSpans() throws Exception {
|
||||
createAndStartClient();
|
||||
|
||||
|
|
|
@ -14,7 +14,7 @@ import static org.assertj.core.api.Assertions.assertThat;
|
|||
|
||||
import io.opentelemetry.api.trace.SpanKind;
|
||||
import io.opentelemetry.sdk.testing.assertj.SpanDataAssert;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
|
||||
class AwsSpanAssertions {
|
||||
|
||||
|
@ -33,6 +33,7 @@ class AwsSpanAssertions {
|
|||
return sqs(span, spanName, queueUrl, queueName, CLIENT);
|
||||
}
|
||||
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
static SpanDataAssert sqs(
|
||||
SpanDataAssert span, String spanName, String queueUrl, String queueName, SpanKind spanKind) {
|
||||
|
||||
|
@ -88,6 +89,7 @@ class AwsSpanAssertions {
|
|||
equalTo(stringKey("rpc.service"), "AmazonSQS"));
|
||||
}
|
||||
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
static SpanDataAssert s3(SpanDataAssert span, String spanName, String bucketName, String method) {
|
||||
return span.hasName(spanName)
|
||||
.hasAttributesSatisfyingExactly(
|
||||
|
@ -115,6 +117,7 @@ class AwsSpanAssertions {
|
|||
v -> val.isInstanceOf(Number.class), v -> assertThat(v).isNull())));
|
||||
}
|
||||
|
||||
@SuppressWarnings("deprecation") // until old http semconv are dropped in 2.0
|
||||
static SpanDataAssert sns(SpanDataAssert span, String spanName) {
|
||||
return span.hasName(spanName)
|
||||
.hasKind(CLIENT)
|
||||
|
|
|
@ -11,7 +11,7 @@ import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.satis
|
|||
|
||||
import io.opentelemetry.api.trace.SpanKind;
|
||||
import io.opentelemetry.sdk.testing.assertj.SpanDataAssert;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
|
||||
class CamelSpanAssertions {
|
||||
|
||||
|
|
|
@ -14,7 +14,7 @@ import io.opentelemetry.api.trace.SpanKind;
|
|||
import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
|
||||
import io.opentelemetry.instrumentation.testing.junit.http.AbstractHttpServerUsingTest;
|
||||
import io.opentelemetry.instrumentation.testing.junit.http.HttpServerInstrumentationExtension;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
import org.apache.camel.CamelContext;
|
||||
import org.apache.camel.ProducerTemplate;
|
||||
import org.junit.jupiter.api.AfterAll;
|
||||
|
|
|
@ -13,7 +13,7 @@ import io.opentelemetry.instrumentation.api.instrumenter.db.DbClientSpanNameExtr
|
|||
import io.opentelemetry.instrumentation.api.instrumenter.db.SqlClientAttributesExtractor;
|
||||
import io.opentelemetry.instrumentation.api.instrumenter.network.ServerAttributesExtractor;
|
||||
import io.opentelemetry.javaagent.bootstrap.internal.CommonConfig;
|
||||
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
|
||||
import io.opentelemetry.semconv.SemanticAttributes;
|
||||
|
||||
public final class CassandraSingletons {
|
||||
private static final String INSTRUMENTATION_NAME = "io.opentelemetry.cassandra-3.0";
|
||||
|
|
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in New Issue