add thread details customizer provider

Author: zeitlinger

sdk-autoconfigure-support/build.gradle.kts

@@ -7,6 +7,7 @@ group = "io.opentelemetry.instrumentation"
 
 dependencies {
   api("io.opentelemetry:opentelemetry-sdk-extension-autoconfigure")
+  api("io.opentelemetry:opentelemetry-sdk-extension-incubator")
 
   compileOnly("com.google.code.findbugs:annotations")
   testCompileOnly("com.google.code.findbugs:annotations")

sdk-autoconfigure-support/src/main/java/io/opentelemetry/instrumentation/thread/ThreadDetailsComponentProvider.java

@@ -0,0 +1,22 @@
+package io.opentelemetry.instrumentation.thread;
+
+import io.opentelemetry.api.incubator.config.DeclarativeConfigProperties;
+import io.opentelemetry.sdk.autoconfigure.spi.internal.ComponentProvider;
+import io.opentelemetry.sdk.trace.SpanProcessor;
+
+public class ThreadDetailsComponentProvider implements ComponentProvider<SpanProcessor> {
+  @Override
+  public String getName() {
+    return "thread_details";
+  }
+
+  @Override
+  public SpanProcessor create(DeclarativeConfigProperties config) {
+    return new AddThreadDetailsSpanProcessor();
+  }
+
+  @Override
+  public Class<SpanProcessor> getType() {
+    return SpanProcessor.class;
+  }
+}

sdk-autoconfigure-support/src/main/java/io/opentelemetry/instrumentation/thread/ThreadDetailsConfigurationCustomizerProvider.java

@@ -0,0 +1,24 @@
+package io.opentelemetry.instrumentation.thread;
+
+import io.opentelemetry.sdk.extension.incubator.fileconfig.DeclarativeConfigurationCustomizer;
+import io.opentelemetry.sdk.extension.incubator.fileconfig.DeclarativeConfigurationCustomizerProvider;
+import io.opentelemetry.sdk.extension.incubator.fileconfig.internal.model.SpanProcessorModel;
+import io.opentelemetry.sdk.extension.incubator.fileconfig.internal.model.TracerProviderModel;
+
+public class ThreadDetailsConfigurationCustomizerProvider
+    implements DeclarativeConfigurationCustomizerProvider {
+  @Override
+  public void customize(DeclarativeConfigurationCustomizer customizer) {
+    customizer.addModelCustomizer(
+        model -> {
+          TracerProviderModel tracerProvider = model.getTracerProvider();
+          if (tracerProvider == null) {
+            return model;
+          }
+          tracerProvider
+              .getProcessors()
+              .add(new SpanProcessorModel().withAdditionalProperty("thread_details", null));
+          return model;
+        });
+  }
+}

sdk-autoconfigure-support/src/main/resources/META-INF/services/io.opentelemetry.sdk.autoconfigure.spi.internal.ComponentProvider

@@ -0,0 +1 @@
+io.opentelemetry.instrumentation.thread.ThreadDetailsComponentProvider

sdk-autoconfigure-support/src/main/resources/META-INF/services/io.opentelemetry.sdk.extension.incubator.fileconfig.DeclarativeConfigurationCustomizerProvider

@@ -0,0 +1 @@
+io.opentelemetry.instrumentation.thread.ThreadDetailsConfigurationCustomizerProvider

sdk-autoconfigure-support/src/test/java/io/opentelemetry/instrumentation/thread/ThreadDetailsConfigurationCustomizerProviderTest.java

@@ -0,0 +1,26 @@
+package io.opentelemetry.instrumentation.thread;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+import io.opentelemetry.sdk.OpenTelemetrySdk;
+import io.opentelemetry.sdk.extension.incubator.fileconfig.DeclarativeConfiguration;
+import io.opentelemetry.sdk.extension.incubator.fileconfig.DeclarativeConfigurationBuilder;
+import io.opentelemetry.sdk.extension.incubator.fileconfig.internal.model.OpenTelemetryConfigurationModel;
+import io.opentelemetry.sdk.extension.incubator.fileconfig.internal.model.TracerProviderModel;
+import org.junit.jupiter.api.Test;
+
+class ThreadDetailsConfigurationCustomizerProviderTest {
+
+  @Test
+  void addSpanProcessor() {
+    OpenTelemetryConfigurationModel model =
+        new DeclarativeConfigurationBuilder().customizeModel(
+            new OpenTelemetryConfigurationModel()
+                .withFileFormat("0.4")
+                .withTracerProvider(new TracerProviderModel()));
+
+    try (OpenTelemetrySdk sdk = DeclarativeConfiguration.create(model)) {
+      assertThat(sdk.toString()).containsOnlyOnce("AddThreadDetailsSpanProcessor");
+    }
+  }
+}