Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions .github/config/lychee.toml
Original file line number Diff line number Diff line change
Expand Up @@ -26,4 +26,7 @@ exclude = [
'^https://central.sonatype.com/service/rest/repository/browse/maven-snapshots/io/opentelemetry/$',
# new artifact, remove after 2.21.0 release
'^https://central.sonatype.com/artifact/io.opentelemetry.instrumentation/opentelemetry-helidon-4.3$',
# flaky link
'^http://www.slf4j.org.*',
'^https://logback.qos.ch/.*'
]
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@
import io.opentelemetry.api.incubator.config.ConfigProvider;
import io.opentelemetry.api.incubator.config.DeclarativeConfigProperties;
import io.opentelemetry.sdk.autoconfigure.spi.ConfigProperties;
import javax.annotation.Nullable;

/**
* A {@link ConfigProvider} implementation backed by {@link ConfigProperties}.
Expand All @@ -30,7 +29,6 @@ private ConfigPropertiesBackedConfigProvider(ConfigProperties configProperties)
configProperties);
}

@Nullable
@Override
public DeclarativeConfigProperties getInstrumentationConfig() {
return instrumentationConfig;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
import io.opentelemetry.sdk.autoconfigure.spi.ConfigProperties;
import io.opentelemetry.sdk.extension.incubator.fileconfig.DeclarativeConfiguration;
import io.opentelemetry.sdk.extension.incubator.fileconfig.SdkConfigProvider;
import io.opentelemetry.sdk.extension.incubator.fileconfig.internal.model.InstrumentationModel;
import io.opentelemetry.sdk.extension.incubator.fileconfig.internal.model.ExperimentalInstrumentationModel;
import io.opentelemetry.sdk.extension.incubator.fileconfig.internal.model.OpenTelemetryConfigurationModel;
import java.time.Duration;
import java.util.Arrays;
Expand All @@ -31,7 +31,8 @@ void setup() {

OpenTelemetryConfigurationModel emptyModel =
new OpenTelemetryConfigurationModel()
.withAdditionalProperty("instrumentation/development", new InstrumentationModel());
.withAdditionalProperty(
"instrumentation/development", new ExperimentalInstrumentationModel());
SdkConfigProvider emptyConfigProvider = SdkConfigProvider.create(emptyModel);
emptyBridge =
new DeclarativeConfigPropertiesBridgeBuilder()
Expand Down
2 changes: 1 addition & 1 deletion dependencyManagement/build.gradle.kts
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ plugins {
data class DependencySet(val group: String, val version: String, val modules: List<String>)

// this line is managed by .github/scripts/update-sdk-version.sh
val otelSdkVersion = "1.57.0"
val otelSdkVersion = "1.58.0"
val otelContribVersion = "1.52.0-alpha"
val otelSdkAlphaVersion = otelSdkVersion.replaceFirst("(-SNAPSHOT)?$".toRegex(), "-alpha$1")

Expand Down
2 changes: 1 addition & 1 deletion examples/distro/build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ subprojects {
ext {
versions = [
// this line is managed by .github/scripts/update-sdk-version.sh
opentelemetrySdk : "1.57.0",
opentelemetrySdk : "1.58.0",

// these lines are managed by .github/scripts/update-version.sh
opentelemetryJavaagent : "2.24.0-SNAPSHOT",
Expand Down
2 changes: 1 addition & 1 deletion examples/extension/build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ version '1.0'
ext {
versions = [
// this line is managed by .github/scripts/update-sdk-version.sh
opentelemetrySdk : "1.57.0",
opentelemetrySdk : "1.58.0",

// these lines are managed by .github/scripts/update-version.sh
opentelemetryJavaagent : "2.24.0-SNAPSHOT",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@

import io.opentelemetry.api.OpenTelemetry;
import io.opentelemetry.api.incubator.config.ConfigProvider;
import io.opentelemetry.api.incubator.config.DeclarativeConfigProperties;
import io.opentelemetry.instrumentation.api.incubator.log.LoggingContextConstants;
import io.opentelemetry.instrumentation.api.incubator.semconv.net.PeerServiceResolver;
import io.opentelemetry.instrumentation.api.internal.HttpConstants;
Expand Down Expand Up @@ -44,9 +45,9 @@ interface ValueProvider<T> {
}

public CommonConfig(OpenTelemetry openTelemetry) {
ExtendedDeclarativeConfigProperties generalConfig =
DeclarativeConfigProperties generalConfig =
DeclarativeConfigUtil.getGeneralInstrumentationConfig(openTelemetry);
ExtendedDeclarativeConfigProperties commonConfig =
DeclarativeConfigProperties commonConfig =
DeclarativeConfigUtil.getInstrumentationConfig(openTelemetry, "common");
peerServiceResolver = PeerServiceResolver.create(openTelemetry);

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,25 +19,17 @@ public final class DeclarativeConfigUtil {

private DeclarativeConfigUtil() {}

public static ExtendedDeclarativeConfigProperties getInstrumentationConfig(
public static DeclarativeConfigProperties getInstrumentationConfig(
OpenTelemetry openTelemetry, String instrumentationName) {
return getConfig(openTelemetry).get("java").get(instrumentationName);
return openTelemetry instanceof ExtendedOpenTelemetry
? ((ExtendedOpenTelemetry) openTelemetry).getInstrumentationConfig(instrumentationName)
: empty();
}

public static ExtendedDeclarativeConfigProperties getGeneralInstrumentationConfig(
public static DeclarativeConfigProperties getGeneralInstrumentationConfig(
OpenTelemetry openTelemetry) {
return getConfig(openTelemetry).get("general");
}

private static ExtendedDeclarativeConfigProperties getConfig(OpenTelemetry openTelemetry) {
if (openTelemetry instanceof ExtendedOpenTelemetry) {
ExtendedOpenTelemetry extendedOpenTelemetry = (ExtendedOpenTelemetry) openTelemetry;
DeclarativeConfigProperties instrumentationConfig =
extendedOpenTelemetry.getConfigProvider().getInstrumentationConfig();
if (instrumentationConfig != null) {
return new ExtendedDeclarativeConfigProperties(instrumentationConfig);
}
}
return new ExtendedDeclarativeConfigProperties(empty());
return openTelemetry instanceof ExtendedOpenTelemetry
? ((ExtendedOpenTelemetry) openTelemetry).getGeneralInstrumentationConfig()
: empty();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@

package io.opentelemetry.instrumentation.api.incubator.config.internal;

import io.opentelemetry.api.incubator.config.DeclarativeConfigProperties;
import java.util.Objects;

/**
Expand Down Expand Up @@ -39,7 +40,7 @@ public class EnduserConfig {
private final boolean roleEnabled;
private final boolean scopeEnabled;

EnduserConfig(ExtendedDeclarativeConfigProperties commonConfig) {
EnduserConfig(DeclarativeConfigProperties commonConfig) {
Objects.requireNonNull(commonConfig, "commonConfig must not be null");

/*
Expand Down

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -381,12 +381,10 @@ private String getSpanSuppressionStrategy() {
// we cannot use DeclarativeConfigUtil here because it's not available in instrumentation-api
DeclarativeConfigProperties commonConfig = empty();
if (openTelemetry instanceof ExtendedOpenTelemetry) {
DeclarativeConfigProperties instrumentationConfig =
((ExtendedOpenTelemetry) openTelemetry).getConfigProvider().getInstrumentationConfig();
if (instrumentationConfig != null) {
commonConfig =
instrumentationConfig.getStructured("java", empty()).getStructured("common", empty());
}
commonConfig =
((ExtendedOpenTelemetry) openTelemetry)
.getConfigProvider()
.getInstrumentationConfig("common");
}
String result =
commonConfig.getString(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,8 +13,8 @@
import com.amazonaws.handlers.RequestHandler2;
import io.opentelemetry.api.GlobalOpenTelemetry;
import io.opentelemetry.api.OpenTelemetry;
import io.opentelemetry.api.incubator.config.DeclarativeConfigProperties;
import io.opentelemetry.instrumentation.api.incubator.config.internal.DeclarativeConfigUtil;
import io.opentelemetry.instrumentation.api.incubator.config.internal.ExtendedDeclarativeConfigProperties;
import io.opentelemetry.instrumentation.api.internal.ConfigPropertiesUtil;
import io.opentelemetry.instrumentation.awssdk.v1_11.AwsSdkTelemetry;

Expand All @@ -26,7 +26,7 @@ public class TracingRequestHandler extends RequestHandler2 {
private static final RequestHandler2 DELEGATE = buildDelegate(GlobalOpenTelemetry.get());

private static RequestHandler2 buildDelegate(OpenTelemetry openTelemetry) {
ExtendedDeclarativeConfigProperties messaging =
DeclarativeConfigProperties messaging =
DeclarativeConfigUtil.getInstrumentationConfig(openTelemetry, "common").get("messaging");
return AwsSdkTelemetry.builder(openTelemetry)
.setCaptureExperimentalSpanAttributes(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,8 +9,8 @@

import io.opentelemetry.api.GlobalOpenTelemetry;
import io.opentelemetry.api.OpenTelemetry;
import io.opentelemetry.api.incubator.config.DeclarativeConfigProperties;
import io.opentelemetry.instrumentation.api.incubator.config.internal.DeclarativeConfigUtil;
import io.opentelemetry.instrumentation.api.incubator.config.internal.ExtendedDeclarativeConfigProperties;
import io.opentelemetry.instrumentation.api.internal.ConfigPropertiesUtil;
import io.opentelemetry.instrumentation.awssdk.v2_2.AwsSdkTelemetry;
import java.util.List;
Expand All @@ -35,11 +35,11 @@ private static AwsSdkTelemetry telemetry(boolean useLegacyLibraryConfig) {
AwsSdkTelemetryFactory factory = new AwsSdkTelemetryFactory(useLegacyLibraryConfig);

OpenTelemetry openTelemetry = GlobalOpenTelemetry.get();
ExtendedDeclarativeConfigProperties commonConfig =
DeclarativeConfigProperties commonConfig =
DeclarativeConfigUtil.getInstrumentationConfig(openTelemetry, "common");
ExtendedDeclarativeConfigProperties messaging = commonConfig.get("messaging");
DeclarativeConfigProperties messaging = commonConfig.get("messaging");

ExtendedDeclarativeConfigProperties awsSdk =
DeclarativeConfigProperties awsSdk =
DeclarativeConfigUtil.getInstrumentationConfig(openTelemetry, "aws_sdk");

return AwsSdkTelemetry.builder(openTelemetry)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@
import static org.assertj.core.api.Assertions.assertThat;
import static org.mockito.Mockito.when;

import io.opentelemetry.instrumentation.api.incubator.config.internal.ExtendedDeclarativeConfigProperties;
import io.opentelemetry.api.incubator.config.DeclarativeConfigProperties;
import java.util.Arrays;
import java.util.Collections;
import java.util.HashSet;
Expand All @@ -25,7 +25,7 @@
@ExtendWith(MockitoExtension.class)
class IncludeTest {

@Mock ExtendedDeclarativeConfigProperties config;
@Mock DeclarativeConfigProperties config;

@ParameterizedTest
@MethodSource("provideArguments")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,10 +17,10 @@
import static net.bytebuddy.matcher.ElementMatchers.not;

import io.opentelemetry.api.GlobalOpenTelemetry;
import io.opentelemetry.api.incubator.config.DeclarativeConfigProperties;
import io.opentelemetry.context.Context;
import io.opentelemetry.context.Scope;
import io.opentelemetry.instrumentation.api.incubator.config.internal.DeclarativeConfigUtil;
import io.opentelemetry.instrumentation.api.incubator.config.internal.ExtendedDeclarativeConfigProperties;
import io.opentelemetry.instrumentation.api.incubator.semconv.util.ClassAndMethod;
import io.opentelemetry.javaagent.extension.instrumentation.TypeInstrumentation;
import io.opentelemetry.javaagent.extension.instrumentation.TypeTransformer;
Expand Down Expand Up @@ -113,8 +113,7 @@ public void transform(TypeTransformer transformer) {
}

// visible for testing
static Set<String> configureAdditionalTraceAnnotations(
ExtendedDeclarativeConfigProperties config) {
static Set<String> configureAdditionalTraceAnnotations(DeclarativeConfigProperties config) {
// First try structured declarative config (YAML list format)
List<String> list = config.getScalarList("include", String.class);
if (list != null) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,8 +8,8 @@
import graphql.execution.instrumentation.Instrumentation;
import io.opentelemetry.api.GlobalOpenTelemetry;
import io.opentelemetry.api.OpenTelemetry;
import io.opentelemetry.api.incubator.config.DeclarativeConfigProperties;
import io.opentelemetry.instrumentation.api.incubator.config.internal.DeclarativeConfigUtil;
import io.opentelemetry.instrumentation.api.incubator.config.internal.ExtendedDeclarativeConfigProperties;
import io.opentelemetry.instrumentation.graphql.internal.InstrumentationUtil;
import io.opentelemetry.instrumentation.graphql.v12_0.GraphQLTelemetry;

Expand Down Expand Up @@ -49,7 +49,7 @@ private static final class Configuration {
private final boolean addOperationNameToSpanName;

Configuration(OpenTelemetry openTelemetry) {
ExtendedDeclarativeConfigProperties config =
DeclarativeConfigProperties config =
DeclarativeConfigUtil.getInstrumentationConfig(openTelemetry, "graphql");

this.captureQuery = config.getBoolean("capture_query", true);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,8 +8,8 @@
import graphql.execution.instrumentation.Instrumentation;
import io.opentelemetry.api.GlobalOpenTelemetry;
import io.opentelemetry.api.OpenTelemetry;
import io.opentelemetry.api.incubator.config.DeclarativeConfigProperties;
import io.opentelemetry.instrumentation.api.incubator.config.internal.DeclarativeConfigUtil;
import io.opentelemetry.instrumentation.api.incubator.config.internal.ExtendedDeclarativeConfigProperties;
import io.opentelemetry.instrumentation.graphql.internal.InstrumentationUtil;
import io.opentelemetry.instrumentation.graphql.v20_0.GraphQLTelemetry;

Expand Down Expand Up @@ -57,7 +57,7 @@ private static final class Configuration {
private final boolean addOperationNameToSpanName;

Configuration(OpenTelemetry openTelemetry) {
ExtendedDeclarativeConfigProperties config =
DeclarativeConfigProperties config =
DeclarativeConfigUtil.getInstrumentationConfig(openTelemetry, "graphql");

this.captureQuery = config.getBoolean("capture_query", true);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,8 +13,8 @@
import io.grpc.ServerBuilder;
import io.grpc.ServerInterceptor;
import io.opentelemetry.api.GlobalOpenTelemetry;
import io.opentelemetry.api.incubator.config.DeclarativeConfigProperties;
import io.opentelemetry.instrumentation.api.incubator.config.internal.DeclarativeConfigUtil;
import io.opentelemetry.instrumentation.api.incubator.config.internal.ExtendedDeclarativeConfigProperties;
import io.opentelemetry.instrumentation.api.util.VirtualField;
import io.opentelemetry.instrumentation.grpc.v1_6.GrpcTelemetry;
import io.opentelemetry.instrumentation.grpc.v1_6.internal.ContextStorageBridge;
Expand All @@ -38,7 +38,7 @@ public final class GrpcSingletons {
private static final AtomicReference<Context.Storage> STORAGE_REFERENCE = new AtomicReference<>();

static {
ExtendedDeclarativeConfigProperties config =
DeclarativeConfigProperties config =
DeclarativeConfigUtil.getInstrumentationConfig(GlobalOpenTelemetry.get(), "grpc");
boolean emitMessageEvents = config.getBoolean("emit_message_events", true);

Expand Down
Loading
Loading