[vertx_quarkus_fork]

Add fork of Quarkus vertx-based gRPC exporters Create new module for exporters Bump version Add testcontainer-based testing of new exporters
smallrye · Nov 29, 2023 · 18533f5 · 18533f5
1 parent 4914577
commit 18533f5
Show file tree

Hide file tree

Showing 24 changed files with 1,008 additions and 13 deletions.
diff --git a/api/pom.xml b/api/pom.xml
@@ -4,7 +4,7 @@
     <parent>
         <groupId>io.smallrye.opentelemetry</groupId>
         <artifactId>smallrye-opentelemetry-parent</artifactId>
-        <version>2.5.2-SNAPSHOT</version>
+        <version>2.6.0-SNAPSHOT</version>
     </parent>
 
     <artifactId>smallrye-opentelemetry-api</artifactId>

diff --git a/examples/agent/pom.xml b/examples/agent/pom.xml
@@ -11,7 +11,7 @@
 
     <groupId>io.smallrye.opentelemetry.examples</groupId>
     <artifactId>agent</artifactId>
-    <version>2.5.2-SNAPSHOT</version>
+    <version>2.6.0-SNAPSHOT</version>
     <packaging>war</packaging>
     <name>SmallRye OpenTelemetry Examples: Agent</name>
 

diff --git a/examples/library/pom.xml b/examples/library/pom.xml
@@ -11,7 +11,7 @@
 
     <groupId>io.smallrye.opentelemetry.examples</groupId>
     <artifactId>library</artifactId>
-    <version>2.5.2-SNAPSHOT</version>
+    <version>2.6.0-SNAPSHOT</version>
     <packaging>war</packaging>
     <name>SmallRye OpenTelemetry Examples: Library</name>
 

diff --git a/examples/pom.xml b/examples/pom.xml
@@ -20,7 +20,7 @@
     <parent>
         <groupId>io.smallrye.opentelemetry</groupId>
         <artifactId>smallrye-opentelemetry-parent</artifactId>
-        <version>2.5.2-SNAPSHOT</version>
+        <version>2.6.0-SNAPSHOT</version>
     </parent>
 
     <groupId>io.smallrye.config.examples</groupId>

diff --git a/implementation/cdi/pom.xml b/implementation/cdi/pom.xml
@@ -4,7 +4,7 @@
     <parent>
         <groupId>io.smallrye.opentelemetry</groupId>
         <artifactId>smallrye-opentelemetry-parent</artifactId>
-        <version>2.5.2-SNAPSHOT</version>
+        <version>2.6.0-SNAPSHOT</version>
         <relativePath>../../pom.xml</relativePath>
     </parent>
 

diff --git a/implementation/config/pom.xml b/implementation/config/pom.xml
@@ -4,7 +4,7 @@
     <parent>
         <groupId>io.smallrye.opentelemetry</groupId>
         <artifactId>smallrye-opentelemetry-parent</artifactId>
-        <version>2.5.2-SNAPSHOT</version>
+        <version>2.6.0-SNAPSHOT</version>
         <relativePath>../../pom.xml</relativePath>
     </parent>
 

diff --git a/implementation/exporters/pom.xml b/implementation/exporters/pom.xml
@@ -0,0 +1,92 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>io.smallrye.opentelemetry</groupId>
+        <artifactId>smallrye-opentelemetry-parent</artifactId>
+        <version>2.6.0-SNAPSHOT</version>
+        <relativePath>../../pom.xml</relativePath>
+    </parent>
+
+    <artifactId>smallrye-opentelemetry-exporters</artifactId>
+    <name>SmallRye OpenTelemetry: Exporters</name>
+
+    <dependencies>
+        <dependency>
+            <groupId>io.smallrye.opentelemetry</groupId>
+            <artifactId>smallrye-opentelemetry-api</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>io.smallrye.config</groupId>
+            <artifactId>smallrye-config</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>jakarta.enterprise</groupId>
+            <artifactId>jakarta.enterprise.cdi-api</artifactId>
+            <scope>provided</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>io.opentelemetry</groupId>
+            <artifactId>opentelemetry-exporter-common</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>io.vertx</groupId>
+            <artifactId>vertx-core</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>io.vertx</groupId>
+            <artifactId>vertx-grpc-client</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>io.opentelemetry</groupId>
+            <artifactId>opentelemetry-exporter-otlp-common</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>io.opentelemetry</groupId>
+            <artifactId>opentelemetry-exporter-otlp</artifactId>
+        </dependency>
+
+        <!-- Test Dependencies -->
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.awaitility</groupId>
+            <artifactId>awaitility</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.jboss.weld</groupId>
+            <artifactId>weld-junit5</artifactId>
+            <exclusions>
+                <exclusion>
+                    <groupId>javax.enterprise</groupId>
+                    <artifactId>cdi-api</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+        <dependency>
+            <groupId>io.smallrye.config</groupId>
+            <artifactId>smallrye-config</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>io.smallrye.opentelemetry</groupId>
+            <artifactId>smallrye-opentelemetry-config</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.testcontainers</groupId>
+            <artifactId>testcontainers</artifactId>
+            <version>${version.testcontainers}</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>io.smallrye.opentelemetry</groupId>
+            <artifactId>smallrye-opentelemetry-cdi</artifactId>
+            <scope>test</scope>
+        </dependency>
+
+    </dependencies>
+</project>
diff --git a/.../src/main/java/io/smallrye/opentelemetry/implementation/exporters/BufferOutputStream.java b/.../src/main/java/io/smallrye/opentelemetry/implementation/exporters/BufferOutputStream.java
@@ -0,0 +1,25 @@
+package io.smallrye.opentelemetry.implementation.exporters;
+
+import java.io.IOException;
+import java.io.OutputStream;
+
+import io.vertx.core.buffer.Buffer;
+
+final class BufferOutputStream extends OutputStream {
+
+    private final Buffer buffer;
+
+    public BufferOutputStream(Buffer buffer) {
+        this.buffer = buffer;
+    }
+
+    @Override
+    public void write(byte[] b, int off, int len) throws IOException {
+        buffer.appendBytes(b, off, len);
+    }
+
+    @Override
+    public void write(int b) throws IOException {
+        buffer.appendInt(b);
+    }
+}
diff --git a/...rs/src/main/java/io/smallrye/opentelemetry/implementation/exporters/OtlpExporterUtil.java b/...rs/src/main/java/io/smallrye/opentelemetry/implementation/exporters/OtlpExporterUtil.java
@@ -0,0 +1,38 @@
+package io.smallrye.opentelemetry.implementation.exporters;
+
+import java.net.URI;
+import java.util.HashMap;
+import java.util.Locale;
+import java.util.Map;
+
+import io.opentelemetry.exporter.otlp.internal.OtlpUserAgent;
+
+final class OtlpExporterUtil {
+    static String OTEL_EXPORTER_OTLP_ENDPOINT = "otel.exporter.otlp.endpoint";
+    static String OTEL_EXPORTER_OTLP_TIMEOUT = "otel.exporter.otlp.timeout";
+
+    private OtlpExporterUtil() {
+    }
+
+    static int getPort(URI uri) {
+        int originalPort = uri.getPort();
+        if (originalPort > -1) {
+            return originalPort;
+        }
+
+        if (isHttps(uri)) {
+            return 443;
+        }
+        return 80;
+    }
+
+    public static Map<String, String> populateTracingExportHttpHeaders() {
+        Map<String, String> headersMap = new HashMap<>();
+        OtlpUserAgent.addUserAgentHeader(headersMap::put);
+        return headersMap;
+    }
+
+    static boolean isHttps(URI uri) {
+        return "https".equals(uri.getScheme().toLowerCase(Locale.ROOT));
+    }
+}