open-telemetry
/
opentelemetry-java
mirror of https://github.com/open-telemetry/opentelemetry-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add exemplar to otlp integration test (#5460)

This commit is contained in:
jack-berg 2023-05-17 17:22:42 -05:00 committed by GitHub
parent 0230d9d133
commit 0bad3c982a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
integration-tests/otlp/src/main/java/io/opentelemetry/integrationtest/OtlpExporterIntegrationTest.java
View File

@ -61,8 +61,11 @@ import io.opentelemetry.sdk.logs.export.BatchLogRecordProcessor;
import io.opentelemetry.sdk.logs.export.LogRecordExporter; import io.opentelemetry.sdk.logs.export.LogRecordExporter;
import io.opentelemetry.sdk.logs.internal.SdkEventEmitterProvider; import io.opentelemetry.sdk.logs.internal.SdkEventEmitterProvider;
import io.opentelemetry.sdk.metrics.SdkMeterProvider; import io.opentelemetry.sdk.metrics.SdkMeterProvider;
import io.opentelemetry.sdk.metrics.SdkMeterProviderBuilder;
import io.opentelemetry.sdk.metrics.export.MetricExporter; import io.opentelemetry.sdk.metrics.export.MetricExporter;
import io.opentelemetry.sdk.metrics.export.PeriodicMetricReader; import io.opentelemetry.sdk.metrics.export.PeriodicMetricReader;
import io.opentelemetry.sdk.metrics.internal.SdkMeterProviderUtil;
import io.opentelemetry.sdk.metrics.internal.exemplar.ExemplarFilter;
import io.opentelemetry.sdk.resources.Resource; import io.opentelemetry.sdk.resources.Resource;
import io.opentelemetry.sdk.trace.IdGenerator; import io.opentelemetry.sdk.trace.IdGenerator;
import io.opentelemetry.sdk.trace.SdkTracerProvider; import io.opentelemetry.sdk.trace.SdkTracerProvider;
@ -379,14 +382,18 @@ abstract class OtlpExporterIntegrationTest {
} }
private static void testMetricExport(MetricExporter metricExporter) { private static void testMetricExport(MetricExporter metricExporter) {
SdkMeterProvider meterProvider = SdkMeterProviderBuilder meterProviderBuilder =
SdkMeterProvider.builder() SdkMeterProvider.builder()
.setResource(RESOURCE) .setResource(RESOURCE)
.registerMetricReader( .registerMetricReader(
PeriodicMetricReader.builder(metricExporter) PeriodicMetricReader.builder(metricExporter)
.setInterval(Duration.ofSeconds(Integer.MAX_VALUE)) .setInterval(Duration.ofSeconds(Integer.MAX_VALUE))
.build()) .build());
.build();
// Enable alwaysOn exemplar filter, instead of default traceBased filter
SdkMeterProviderUtil.setExemplarFilter(meterProviderBuilder, ExemplarFilter.alwaysOn());
SdkMeterProvider meterProvider = meterProviderBuilder.build();
Meter meter = meterProvider.meterBuilder(OtlpExporterIntegrationTest.class.getName()).build(); Meter meter = meterProvider.meterBuilder(OtlpExporterIntegrationTest.class.getName()).build();
@ -435,6 +442,7 @@ abstract class OtlpExporterIntegrationTest {
.setKey("key") .setKey("key")
.setValue(AnyValue.newBuilder().setStringValue("value").build()) .setValue(AnyValue.newBuilder().setStringValue("value").build())
.build())); .build()));
assertThat(dataPoint.getExemplarsCount()).isEqualTo(1);
} }
@ParameterizedTest @ParameterizedTest