Skip to content

Commit 1036ffc

Browse files
Merge pull request #1 from zeitlinger/add-baggage-log-record-processor-log-testing
add simple log test
2 parents 16f5ad2 + f00c37c commit 1036ffc

File tree

1 file changed

+13
-6
lines changed

1 file changed

+13
-6
lines changed

baggage-processor/src/test/java/io/opentelemetry/contrib/baggage/processor/BaggageProcessorCustomizerTest.java

Lines changed: 13 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@
55

66
package io.opentelemetry.contrib.baggage.processor;
77

8+
import static org.assertj.core.api.Assertions.assertThat;
89
import static org.awaitility.Awaitility.await;
910
import static org.mockito.Mockito.verify;
1011

@@ -23,6 +24,7 @@
2324
import io.opentelemetry.sdk.autoconfigure.spi.logs.ConfigurableLogRecordExporterProvider;
2425
import io.opentelemetry.sdk.autoconfigure.spi.traces.ConfigurableSpanExporterProvider;
2526
import io.opentelemetry.sdk.logs.ReadWriteLogRecord;
27+
import io.opentelemetry.sdk.logs.data.LogRecordData;
2628
import io.opentelemetry.sdk.logs.export.LogRecordExporter;
2729
import io.opentelemetry.sdk.testing.assertj.SpanDataAssert;
2830
import io.opentelemetry.sdk.testing.assertj.TracesAssert;
@@ -74,10 +76,13 @@ private static void assertCustomizer(
7476
await()
7577
.atMost(Duration.ofSeconds(1))
7678
.untilAsserted(
77-
() ->
78-
TracesAssert.assertThat(spanExporter.getFinishedSpanItems())
79-
.hasTracesSatisfyingExactly(
80-
trace -> trace.hasSpansSatisfyingExactly(spanDataAssertConsumer)));
79+
() -> {
80+
TracesAssert.assertThat(spanExporter.getFinishedSpanItems())
81+
.hasTracesSatisfyingExactly(
82+
trace -> trace.hasSpansSatisfyingExactly(spanDataAssertConsumer));
83+
List<LogRecordData> finishedLogRecordItems = logExporter.getFinishedLogRecordItems();
84+
assertThat(finishedLogRecordItems).hasSize(1);
85+
});
8186
}
8287

8388
private static OpenTelemetrySdk getOpenTelemetrySdk(
@@ -91,9 +96,11 @@ private static OpenTelemetrySdk getOpenTelemetrySdk(
9196
.addPropertiesSupplier(
9297
() ->
9398
ImmutableMap.of(
94-
// We set the export interval of the spans to 100 ms. The default value is 5
99+
// We set the export interval of the spans to 10 ms. The default value is 5
95100
// seconds.
96-
"otel.bsp.schedule.delay",
101+
"otel.bsp.schedule.delay", // span exporter
102+
"10",
103+
"otel.blrp.schedule.delay", // log exporter
97104
"10",
98105
"otel.traces.exporter",
99106
MEMORY_EXPORTER,

0 commit comments

Comments
 (0)