Bump to OTel 1.28

bom/application/pom.xml

@@ -36,8 +36,8 @@
         <opentracing-jdbc.version>0.2.4</opentracing-jdbc.version>
         <opentracing-kafka.version>0.1.15</opentracing-kafka.version>
         <opentracing-mongo.version>0.1.5</opentracing-mongo.version>
-        <opentelemetry.version>1.25.0</opentelemetry.version>
-        <opentelemetry-alpha.version>1.25.0-alpha</opentelemetry-alpha.version>
+        <opentelemetry.version>1.28.0</opentelemetry.version>
+        <opentelemetry-alpha.version>1.28.0-alpha</opentelemetry-alpha.version>
         <jaeger.version>1.8.1</jaeger.version>
         <quarkus-http.version>5.0.2.Final</quarkus-http.version>
         <micrometer.version>1.11.1</micrometer.version><!-- keep in sync with hdrhistogram -->

extensions/opentelemetry/deployment/src/test/java/io/quarkus/opentelemetry/deployment/instrumentation/VertxClientOpenTelemetryTest.java

@@ -131,6 +131,40 @@ void path() throws Exception {
         assertEquals(client.getTraceId(), server.getTraceId());
     }
 
+    @Test
+    void query() throws Exception {
+        HttpResponse<Buffer> response = WebClient.create(vertx)
+                .get(uri.getPort(), uri.getHost(), "/hello?name=foo")
+                .send()
+                .toCompletionStage().toCompletableFuture()
+                .get();
+
+        assertEquals(HTTP_OK, response.statusCode());
+
+        List<SpanData> spans = spanExporter.getFinishedSpanItems(2);
+
+        SpanData client = getSpanByKindAndParentId(spans, CLIENT, "0000000000000000");
+        assertEquals(CLIENT, client.getKind());
+        assertEquals("GET", client.getName());
+        assertEquals(HTTP_OK, client.getAttributes().get(HTTP_STATUS_CODE));
+        assertEquals(HttpMethod.GET, client.getAttributes().get(HTTP_METHOD));
+        assertEquals(uri.toString() + "hello?name=foo", client.getAttributes().get(HTTP_URL));
+        assertEquals(uri.getHost(), client.getAttributes().get(NET_PEER_NAME));
+        assertEquals(uri.getPort(), client.getAttributes().get(NET_PEER_PORT));
+
+        SpanData server = getSpanByKindAndParentId(spans, SERVER, client.getSpanId());
+        assertEquals(SERVER, server.getKind());
+        assertEquals("GET /hello", server.getName());
+        assertEquals(HTTP_OK, server.getAttributes().get(HTTP_STATUS_CODE));
+        assertEquals(HttpMethod.GET, server.getAttributes().get(HTTP_METHOD));
+        assertEquals("/hello", server.getAttributes().get(HTTP_ROUTE));
+        assertEquals(uri.getHost(), server.getAttributes().get(NET_HOST_NAME));
+        assertEquals(uri.getPort(), server.getAttributes().get(NET_HOST_PORT));
+        assertEquals(uri.getPath() + "hello?name=foo", server.getAttributes().get(HTTP_TARGET));
+
+        assertEquals(client.getTraceId(), server.getTraceId());
+    }
+
     @Test
     void multiple() throws Exception {
         HttpResponse<Buffer> response = WebClient.create(vertx)
@@ -165,6 +199,7 @@ public void register(@Observes StartupEvent ev) {
                 Future<HttpResponse<Buffer>> two = webClient.get(port, host, "/hello/goku").send();
                 CompositeFuture.join(one, two).onComplete(event -> rc.response().end());
             });
+            router.get("/hello?name=foo").handler(rc -> rc.response().end("hello foo"));
         }
     }
 }

extensions/opentelemetry/runtime/pom.xml

@@ -83,6 +83,10 @@
             <groupId>io.opentelemetry</groupId>
             <artifactId>opentelemetry-semconv</artifactId>
         </dependency>
+        <dependency>
+            <groupId>io.opentelemetry</groupId>
+            <artifactId>opentelemetry-api-events</artifactId>
+        </dependency>
         <dependency>
             <groupId>io.opentelemetry.instrumentation</groupId>
             <artifactId>opentelemetry-instrumentation-api</artifactId>

extensions/opentelemetry/runtime/src/main/java/io/quarkus/opentelemetry/runtime/OpenTelemetryProducer.java

@@ -81,16 +81,16 @@ public OpenTelemetry getOpenTelemetry() {
 
         if (oTelRuntimeConfig.sdkDisabled()) {
             return AutoConfiguredOpenTelemetrySdk.builder()
-                    .setResultAsGlobal(true)
-                    .registerShutdownHook(false)
+                    .setResultAsGlobal()
+                    .disableShutdownHook()
                     .addPropertiesSupplier(() -> oTelConfigs)
                     .build()
                     .getOpenTelemetrySdk();
         }
 
         final AutoConfiguredOpenTelemetrySdk autoConfiguredOpenTelemetrySdk = AutoConfiguredOpenTelemetrySdk.builder()
-                .setResultAsGlobal(true)
-                .registerShutdownHook(false)
+                .setResultAsGlobal()
+                .disableShutdownHook()
                 .addPropertiesSupplier(() -> oTelConfigs)
                 .setServiceClassLoader(Thread.currentThread().getContextClassLoader())
                 // no customization needed for spanExporter. Loads SPI from CDI

extensions/opentelemetry/runtime/src/main/java/io/quarkus/opentelemetry/runtime/OpenTelemetryRecorder.java

@@ -4,7 +4,6 @@
 
 import io.opentelemetry.api.GlobalOpenTelemetry;
 import io.opentelemetry.api.events.GlobalEventEmitterProvider;
-import io.opentelemetry.api.logs.GlobalLoggerProvider;
 import io.opentelemetry.context.ContextStorage;
 import io.quarkus.runtime.annotations.Recorder;
 import io.vertx.core.Vertx;
@@ -17,7 +16,6 @@ public class OpenTelemetryRecorder {
     /* STATIC INIT */
     public void resetGlobalOpenTelemetryForDevMode() {
         GlobalOpenTelemetry.resetForTest();
-        GlobalLoggerProvider.resetForTest();
         GlobalEventEmitterProvider.resetForTest();
     }
 

extensions/opentelemetry/runtime/src/main/java/io/quarkus/opentelemetry/runtime/exporter/otlp/OtlpRecorder.java

@@ -16,7 +16,7 @@
 
 import io.opentelemetry.api.metrics.MeterProvider;
 import io.opentelemetry.exporter.internal.ExporterBuilderUtil;
-import io.opentelemetry.exporter.internal.otlp.OtlpUserAgent;
+import io.opentelemetry.exporter.otlp.internal.OtlpUserAgent;
 import io.opentelemetry.sdk.trace.export.BatchSpanProcessor;
 import io.opentelemetry.sdk.trace.export.BatchSpanProcessorBuilder;
 import io.opentelemetry.sdk.trace.export.SpanExporter;

extensions/opentelemetry/runtime/src/main/java/io/quarkus/opentelemetry/runtime/graal/Substitutions.java

@@ -48,11 +48,11 @@ static void configureLoggerProvider(
         }
     }
 
-    @TargetClass(className = "io.opentelemetry.api.events.GlobalEventEmitterProvider")
-    static final class Target_GlobalEventEmitterProvider {
-        @Substitute
-        public static void set(EventEmitterProvider eventEmitterProvider) {
-            // do nothing. We don't support events yet. Default is EventEmitterProvider.noop()
+        @TargetClass(className = "io.opentelemetry.api.events.GlobalEventEmitterProvider")
+        static final class Target_GlobalEventEmitterProvider {
+            @Substitute
+            public static void set(EventEmitterProvider eventEmitterProvider) {
+                // do nothing. We don't support events yet. Default is EventEmitterProvider.noop()
+            }
         }
-    }
 }

extensions/opentelemetry/runtime/src/main/java/io/quarkus/opentelemetry/runtime/tracing/cdi/WithSpanInterceptor.java

@@ -37,7 +37,7 @@ public WithSpanInterceptor(final OpenTelemetry openTelemetry) {
                 INSTRUMENTATION_NAME,
                 new MethodRequestSpanNameExtractor());
 
-        MethodSpanAttributesExtractor<MethodRequest, Void> attributesExtractor = MethodSpanAttributesExtractor.newInstance(
+        MethodSpanAttributesExtractor<MethodRequest, Void> attributesExtractor = MethodSpanAttributesExtractor.create(
                 MethodRequest::getMethod,
                 new WithSpanParameterAttributeNamesExtractor(),
                 MethodRequest::getArgs);

extensions/opentelemetry/runtime/src/main/java/io/quarkus/opentelemetry/runtime/tracing/intrumentation/grpc/GrpcRequest.java

@@ -1,21 +1,48 @@
 package io.quarkus.opentelemetry.runtime.tracing.intrumentation.grpc;
 
+import java.net.SocketAddress;
+
 import io.grpc.Attributes;
 import io.grpc.Metadata;
 import io.grpc.MethodDescriptor;
 
 public class GrpcRequest {
+
+    public static GrpcRequest server(
+            final MethodDescriptor<?, ?> methodDescriptor,
+            final Metadata metadata,
+            final Attributes attributes,
+            final String authority) {
+        return new GrpcRequest(methodDescriptor, metadata, attributes, null, authority);
+    }
+
+    public static GrpcRequest client(final MethodDescriptor<?, ?> methodDescriptor, String authority) {
+        return new GrpcRequest(methodDescriptor, null, null, null, authority);
+    }
+
+    public static GrpcRequest client(final MethodDescriptor<?, ?> methodDescriptor, final Metadata metadata) {
+        return new GrpcRequest(methodDescriptor, metadata, null, null, null);
+    }
+
     private final MethodDescriptor<?, ?> methodDescriptor;
-    private final Metadata metadata;
+    private Metadata metadata;
     private final Attributes attributes;
 
+    private volatile String logicalHost;
+    private volatile int logicalPort = -1;
+    private volatile SocketAddress peerSocketAddress;
+
     private GrpcRequest(
             final MethodDescriptor<?, ?> methodDescriptor,
             final Metadata metadata,
-            final Attributes attributes) {
+            final Attributes attributes,
+            final SocketAddress peerSocketAddress,
+            final String authority) {
         this.methodDescriptor = methodDescriptor;
         this.metadata = metadata;
         this.attributes = attributes;
+        this.peerSocketAddress = peerSocketAddress;
+        setLogicalAddress(authority);
     }
 
     public MethodDescriptor<?, ?> getMethodDescriptor() {
@@ -26,22 +53,44 @@ public Metadata getMetadata() {
         return metadata;
     }
 
-    public Attributes getAttributes() {
-        return attributes;
+    void setMetadata(Metadata metadata) {
+        this.metadata = metadata;
     }
 
-    public static GrpcRequest server(
-            final MethodDescriptor<?, ?> methodDescriptor,
-            final Metadata metadata,
-            final Attributes attributes) {
-        return new GrpcRequest(methodDescriptor, metadata, attributes);
+    public String getLogicalHost() {
+        return logicalHost;
     }
 
-    public static GrpcRequest client(final MethodDescriptor<?, ?> methodDescriptor) {
-        return new GrpcRequest(methodDescriptor, null, null);
+    public int getLogicalPort() {
+        return logicalPort;
     }
 
-    public static GrpcRequest client(final MethodDescriptor<?, ?> methodDescriptor, final Metadata metadata) {
-        return new GrpcRequest(methodDescriptor, metadata, null);
+    public SocketAddress getPeerSocketAddress() {
+        return peerSocketAddress;
+    }
+
+    void setPeerSocketAddress(SocketAddress peerSocketAddress) {
+        this.peerSocketAddress = peerSocketAddress;
+    }
+
+    public Attributes getAttributes() {
+        return attributes;
+    }
+
+    private void setLogicalAddress(String authority) {
+        if (authority == null) {
+            return;
+        }
+        int index = authority.indexOf(':');
+        if (index == -1) {
+            logicalHost = authority;
+        } else {
+            logicalHost = authority.substring(0, index);
+            try {
+                logicalPort = Integer.parseInt(authority.substring(index + 1));
+            } catch (NumberFormatException e) {
+                // ignore
+            }
+        }
     }
 }

extensions/opentelemetry/runtime/src/main/java/io/quarkus/opentelemetry/runtime/tracing/intrumentation/grpc/GrpcTracingClientInterceptor.java

@@ -47,7 +47,7 @@ public GrpcTracingClientInterceptor(final OpenTelemetry openTelemetry) {
     public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(
             final MethodDescriptor<ReqT, RespT> method, final CallOptions callOptions, final Channel next) {
 
-        GrpcRequest grpcRequest = GrpcRequest.client(method);
+        GrpcRequest grpcRequest = GrpcRequest.client(method, callOptions.getAuthority());
         Context parentContext = Context.current();
         boolean shouldStart = instrumenter.shouldStart(parentContext, grpcRequest);
         if (shouldStart) {

extensions/opentelemetry/runtime/src/main/java/io/quarkus/opentelemetry/runtime/tracing/intrumentation/grpc/GrpcTracingServerInterceptor.java

@@ -22,8 +22,8 @@
 import io.opentelemetry.context.propagation.TextMapGetter;
 import io.opentelemetry.instrumentation.api.instrumenter.Instrumenter;
 import io.opentelemetry.instrumentation.api.instrumenter.InstrumenterBuilder;
-import io.opentelemetry.instrumentation.api.instrumenter.net.InetSocketAddressNetServerAttributesGetter;
 import io.opentelemetry.instrumentation.api.instrumenter.net.NetServerAttributesExtractor;
+import io.opentelemetry.instrumentation.api.instrumenter.net.NetServerAttributesGetter;
 import io.opentelemetry.instrumentation.api.instrumenter.rpc.RpcServerAttributesExtractor;
 import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
 import io.quarkus.grpc.GlobalInterceptor;
@@ -51,7 +51,8 @@ public GrpcTracingServerInterceptor(final OpenTelemetry openTelemetry) {
     public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(
             final ServerCall<ReqT, RespT> call, final Metadata headers, final ServerCallHandler<ReqT, RespT> next) {
 
-        GrpcRequest grpcRequest = GrpcRequest.server(call.getMethodDescriptor(), headers, call.getAttributes());
+        GrpcRequest grpcRequest = GrpcRequest.server(call.getMethodDescriptor(), headers, call.getAttributes(),
+                call.getAuthority());
         Context parentContext = Context.current();
         boolean shouldStart = instrumenter.shouldStart(parentContext, grpcRequest);
         if (shouldStart) {
@@ -64,24 +65,24 @@ public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(
         return next.startCall(call, headers);
     }
 
-    private static class GrpcServerNetServerAttributesGetter extends InetSocketAddressNetServerAttributesGetter<GrpcRequest> {
+    private static class GrpcServerNetServerAttributesGetter implements NetServerAttributesGetter<GrpcRequest, Status> {
         @Override
         public String getTransport(final GrpcRequest grpcRequest) {
             return SemanticAttributes.NetTransportValues.IP_TCP;
         }
 
         @Override
-        public String getHostName(GrpcRequest grpcRequest) {
-            return null;
+        public String getServerAddress(GrpcRequest grpcRequest) {
+            return grpcRequest.getLogicalHost();
         }
 
         @Override
-        public Integer getHostPort(GrpcRequest grpcRequest) {
-            return null;
+        public Integer getServerPort(GrpcRequest grpcRequest) {
+            return grpcRequest.getLogicalPort();
         }
 
         @Override
-        protected InetSocketAddress getPeerSocketAddress(GrpcRequest grpcRequest) {
+        public InetSocketAddress getClientInetSocketAddress(GrpcRequest grpcRequest, Status status) {
             SocketAddress socketAddress = grpcRequest.getAttributes().get(Grpc.TRANSPORT_ATTR_REMOTE_ADDR);
             if (socketAddress instanceof InetSocketAddress) {
                 return (InetSocketAddress) socketAddress;
@@ -90,7 +91,7 @@ protected InetSocketAddress getPeerSocketAddress(GrpcRequest grpcRequest) {
         }
 
         @Override
-        protected InetSocketAddress getHostSocketAddress(GrpcRequest grpcRequest) {
+        public InetSocketAddress getServerInetSocketAddress(GrpcRequest grpcRequest, Status status) {
             SocketAddress socketAddress = grpcRequest.getAttributes().get(Grpc.TRANSPORT_ATTR_LOCAL_ADDR);
             if (socketAddress instanceof InetSocketAddress) {
                 return (InetSocketAddress) socketAddress;

extensions/opentelemetry/runtime/src/main/java/io/quarkus/opentelemetry/runtime/tracing/intrumentation/restclient/OpenTelemetryClientFilter.java

@@ -147,7 +147,7 @@ private static class ClientAttributesExtractor
             implements HttpClientAttributesGetter<ClientRequestContext, ClientResponseContext> {
 
         @Override
-        public String getUrl(final ClientRequestContext request) {
+        public String getUrlFull(final ClientRequestContext request) {
             URI uri = request.getUri();
             if (uri.getUserInfo() != null) {
                 return UriBuilder.fromUri(uri).userInfo(null).build().toString();
@@ -156,28 +156,23 @@ public String getUrl(final ClientRequestContext request) {
         }
 
         @Override
-        public String getFlavor(final ClientRequestContext request, final ClientResponseContext response) {
-            return null;
-        }
-
-        @Override
-        public String getMethod(final ClientRequestContext request) {
+        public String getHttpRequestMethod(final ClientRequestContext request) {
             return request.getMethod();
         }
 
         @Override
-        public List<String> getRequestHeader(final ClientRequestContext request, final String name) {
+        public List<String> getHttpRequestHeader(final ClientRequestContext request, final String name) {
             return request.getStringHeaders().getOrDefault(name, emptyList());
         }
 
         @Override
-        public Integer getStatusCode(ClientRequestContext clientRequestContext,
+        public Integer getHttpResponseStatusCode(ClientRequestContext clientRequestContext,
                 ClientResponseContext clientResponseContext, Throwable error) {
             return clientResponseContext.getStatus();
         }
 
         @Override
-        public List<String> getResponseHeader(final ClientRequestContext request, final ClientResponseContext response,
+        public List<String> getHttpResponseHeader(final ClientRequestContext request, final ClientResponseContext response,
                 final String name) {
             return response.getHeaders().getOrDefault(name, emptyList());
         }
@@ -192,13 +187,25 @@ public String getTransport(ClientRequestContext clientRequestContext, ClientResp
         }
 
         @Override
-        public String getPeerName(ClientRequestContext clientRequestContext) {
+        public String getServerAddress(ClientRequestContext clientRequestContext) {
             return clientRequestContext.getUri().getHost();
         }
 
         @Override
-        public Integer getPeerPort(ClientRequestContext clientRequestContext) {
+        public Integer getServerPort(ClientRequestContext clientRequestContext) {
             return clientRequestContext.getUri().getPort();
         }
+
+        @Override
+        public String getNetworkProtocolName(ClientRequestContext clientRequestContext,
+                ClientResponseContext clientResponseContext) {
+            return "http";
+        }
+
+        @Override
+        public String getNetworkProtocolVersion(ClientRequestContext clientRequestContext,
+                ClientResponseContext clientResponseContext) {
+            return null;
+        }
     }
 }