ktor

Author: zeitlinger

instrumentation/ktor/ktor-2.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/ktor/v2_0/HttpClientInstrumentation.java

@@ -13,10 +13,10 @@
 import io.ktor.client.HttpClientConfig;
 import io.ktor.client.engine.HttpClientEngineConfig;
 import io.opentelemetry.api.GlobalOpenTelemetry;
-import io.opentelemetry.api.OpenTelemetry;
+import io.opentelemetry.instrumentation.api.incubator.builder.internal.HttpClientInstrumenterBuilder;
 import io.opentelemetry.instrumentation.ktor.v2_0.client.KtorClientTracing;
 import io.opentelemetry.instrumentation.ktor.v2_0.client.KtorClientTracingBuilder;
-import io.opentelemetry.javaagent.bootstrap.internal.AgentCommonConfig;
+import io.opentelemetry.javaagent.bootstrap.internal.CommonConfig;
 import io.opentelemetry.javaagent.extension.instrumentation.TypeInstrumentation;
 import io.opentelemetry.javaagent.extension.instrumentation.TypeTransformer;
 import kotlin.Unit;
@@ -54,12 +54,8 @@ public static class SetupFunction implements Function1<KtorClientTracingBuilder,
 
     @Override
     public Unit invoke(KtorClientTracingBuilder builder) {
-      OpenTelemetry openTelemetry = GlobalOpenTelemetry.get();
-      builder.setOpenTelemetry(openTelemetry);
-      builder.capturedRequestHeaders(AgentCommonConfig.get().getClientRequestHeaders());
-      builder.capturedResponseHeaders(AgentCommonConfig.get().getClientResponseHeaders());
-      builder.knownMethods(AgentCommonConfig.get().getKnownHttpRequestMethods());
-
+      builder.setOpenTelemetry(GlobalOpenTelemetry.get());
+      HttpClientInstrumenterBuilder.configure(CommonConfig.get(), builder);
       return kotlin.Unit.INSTANCE;
     }
   }