Skip to content

Commit

Permalink
Add integration test for otlp http/protobuf log exporter (#3692)
Browse files Browse the repository at this point in the history
  • Loading branch information
jack-berg authored Oct 5, 2021
1 parent 50e2ac7 commit 328f4c2
Show file tree
Hide file tree
Showing 2 changed files with 18 additions and 0 deletions.
1 change: 1 addition & 0 deletions integration-tests/build.gradle.kts
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,7 @@ dependencies {
testImplementation(project(":exporters:otlp:logs"))
testImplementation(project(":exporters:otlp-http:trace"))
testImplementation(project(":exporters:otlp-http:metrics"))
testImplementation(project(":exporters:otlp-http:logs"))
testImplementation(project(":semconv"))
testImplementation(project(":proto"))

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@
import io.opentelemetry.api.trace.TraceFlags;
import io.opentelemetry.api.trace.TraceId;
import io.opentelemetry.api.trace.TraceState;
import io.opentelemetry.exporter.otlp.http.logs.OtlpHttpLogExporter;
import io.opentelemetry.exporter.otlp.http.metrics.OtlpHttpMetricExporter;
import io.opentelemetry.exporter.otlp.http.trace.OtlpHttpSpanExporter;
import io.opentelemetry.exporter.otlp.logs.OtlpGrpcLogExporter;
Expand Down Expand Up @@ -345,6 +346,22 @@ void testOtlpGrpcLogExport() {
testLogExporter(otlpGrpcLogExporter);
}

@Test
void testOtlpHttpLogExport() {
LogExporter otlpHttpLogExporter =
OtlpHttpLogExporter.builder()
.setEndpoint(
"http://"
+ collector.getHost()
+ ":"
+ collector.getMappedPort(COLLECTOR_OTLP_HTTP_PORT)
+ "/v1/logs")
.setCompression("gzip")
.build();

testLogExporter(otlpHttpLogExporter);
}

private static void testLogExporter(LogExporter logExporter) {
LogRecord logRecord =
LogRecord.builder(
Expand Down

0 comments on commit 328f4c2

Please sign in to comment.