Update dependencies (#2115)

This commit is contained in:
Anuraag Agrawal 2020-11-22 02:39:27 +09:00 committed by GitHub
parent 7f4396219e
commit ac672e56bf
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
53 changed files with 191 additions and 157 deletions

View File

@ -16,7 +16,8 @@ dependencies {
signature libraries.android_signature signature libraries.android_signature
testImplementation libraries.jqf testImplementation libraries.jqf,
libraries.guava_testlib
} }
javadoc { javadoc {

View File

@ -2,6 +2,7 @@ import nebula.plugin.release.git.opinion.Strategies
plugins { plugins {
id "com.diffplug.spotless" id "com.diffplug.spotless"
id "com.github.ben-manes.versions"
id "com.jfrog.artifactory" apply false id "com.jfrog.artifactory" apply false
id "com.jfrog.bintray" apply false id "com.jfrog.bintray" apply false
id "nebula.release" id "nebula.release"
@ -284,17 +285,17 @@ configure(opentelemetryProjects) {
errorProneVersion = '2.4.0' errorProneVersion = '2.4.0'
errorProneJavacVersion = '9+181-r4173-1' errorProneJavacVersion = '9+181-r4173-1'
findBugsJsr305Version = '3.0.2' findBugsJsr305Version = '3.0.2'
grpcVersion = '1.30.2' grpcVersion = '1.33.1'
guavaVersion = '28.2-android' guavaVersion = '30.0-android'
jacksonVersion = '2.11.3' jacksonVersion = '2.11.3'
jmhVersion = '1.19' jmhVersion = '1.26'
junitVersion = '5.6.2' junitVersion = '5.7.0'
mockitoVersion = '3.3.3' mockitoVersion = '3.6.0'
opencensusVersion = '0.28.2' opencensusVersion = '0.28.2'
opentracingVersion = '0.33.0' opentracingVersion = '0.33.0'
prometheusVersion = '0.8.1' prometheusVersion = '0.9.0'
protobufVersion = '3.11.4' protobufVersion = '3.14.0'
protocVersion = '3.11.4' protocVersion = '3.14.0'
zipkinReporterVersion = '2.12.2' zipkinReporterVersion = '2.12.2'
zipkinVersion = '2.18.3' zipkinVersion = '2.18.3'
@ -337,10 +338,10 @@ configure(opentelemetryProjects) {
opentracing : "io.opentracing:opentracing-api:${opentracingVersion}", opentracing : "io.opentracing:opentracing-api:${opentracingVersion}",
// Test dependencies. // Test dependencies.
assertj : "org.assertj:assertj-core:3.16.1", assertj : "org.assertj:assertj-core:3.18.1",
guava_testlib : "com.google.guava:guava-testlib", guava_testlib : "com.google.guava:guava-testlib",
junit : 'junit:junit:4.12', junit : 'junit:junit:4.13.1',
junit_pioneer : 'org.junit-pioneer:junit-pioneer:0.7.0', junit_pioneer : 'org.junit-pioneer:junit-pioneer:1.0.0',
junit_jupiter_api : 'org.junit.jupiter:junit-jupiter-api', junit_jupiter_api : 'org.junit.jupiter:junit-jupiter-api',
junit_jupiter_engine : 'org.junit.jupiter:junit-jupiter-engine', junit_jupiter_engine : 'org.junit.jupiter:junit-jupiter-engine',
junit_vintage_engine : 'org.junit.vintage:junit-vintage-engine', junit_vintage_engine : 'org.junit.vintage:junit-vintage-engine',
@ -348,17 +349,17 @@ configure(opentelemetryProjects) {
mockito_junit_jupiter : "org.mockito:mockito-junit-jupiter:${mockitoVersion}", mockito_junit_jupiter : "org.mockito:mockito-junit-jupiter:${mockitoVersion}",
okhttp : 'com.squareup.okhttp3:okhttp:3.14.9', okhttp : 'com.squareup.okhttp3:okhttp:3.14.9',
system_rules : 'com.github.stefanbirkner:system-rules:1.19.0', // env and system properties system_rules : 'com.github.stefanbirkner:system-rules:1.19.0', // env and system properties
slf4jsimple : 'org.slf4j:slf4j-simple:1.7.25', // Compatibility layer slf4jsimple : 'org.slf4j:slf4j-simple:1.7.30', // Compatibility layer
awaitility : 'org.awaitility:awaitility:3.0.0', // Compatibility layer awaitility : 'org.awaitility:awaitility:4.0.3',
testcontainers : 'org.testcontainers:junit-jupiter:1.15.0-rc2', testcontainers : 'org.testcontainers:junit-jupiter:1.15.0',
rest_assured : 'io.rest-assured:rest-assured:4.2.0', rest_assured : 'io.rest-assured:rest-assured:4.2.0',
jaeger_client : 'io.jaegertracing:jaeger-client:1.2.0', // Jaeger Client jaeger_client : 'io.jaegertracing:jaeger-client:1.5.0', // Jaeger Client
zipkin_junit : "io.zipkin.zipkin2:zipkin-junit:${zipkinVersion}", // Zipkin JUnit rule zipkin_junit : "io.zipkin.zipkin2:zipkin-junit:${zipkinVersion}", // Zipkin JUnit rule
archunit : 'com.tngtech.archunit:archunit-junit4:0.13.1', //Architectural constraints archunit : 'com.tngtech.archunit:archunit-junit4:0.14.1', //Architectural constraints
jqf : 'edu.berkeley.cs.jqf:jqf-fuzz:1.6', // fuzz testing jqf : 'edu.berkeley.cs.jqf:jqf-fuzz:1.6', // fuzz testing
// Tooling // Tooling
android_signature : 'com.toasttab.android:gummy-bears-api-24:0.2.0:coreLib@signature' android_signature : 'com.toasttab.android:gummy-bears-api-24:0.3.0:coreLib@signature'
] ]
} }
@ -404,12 +405,15 @@ configure(opentelemetryProjects) {
libraries.errorprone_annotation, libraries.errorprone_annotation,
libraries.jsr305 libraries.jsr305
testCompileOnly libraries.auto_value_annotation,
libraries.errorprone_annotation,
libraries.jsr305
testImplementation libraries.junit_jupiter_api, testImplementation libraries.junit_jupiter_api,
libraries.mockito, libraries.mockito,
libraries.mockito_junit_jupiter, libraries.mockito_junit_jupiter,
libraries.assertj, libraries.assertj,
libraries.awaitility, libraries.awaitility
libraries.guava_testlib
testRuntimeOnly libraries.junit_jupiter_engine, testRuntimeOnly libraries.junit_jupiter_engine,
libraries.junit_vintage_engine libraries.junit_vintage_engine

View File

@ -25,11 +25,12 @@ dependencies {
grpcInOtelTestImplementation libraries.grpc_context grpcInOtelTestImplementation libraries.grpc_context
otelInGrpcTestImplementation libraries.grpc_context otelInGrpcTestImplementation libraries.grpc_context
braveInOtelTestImplementation "io.zipkin.brave:brave:5.12.6" braveInOtelTestImplementation "io.zipkin.brave:brave:5.13.1"
otelAsBraveTestImplementation "io.zipkin.brave:brave:5.12.6" otelAsBraveTestImplementation "io.zipkin.brave:brave:5.13.1"
otelInBraveTestImplementation "io.zipkin.brave:brave:5.12.6" otelInBraveTestImplementation "io.zipkin.brave:brave:5.13.1"
testImplementation libraries.awaitility testImplementation libraries.awaitility
testImplementation libraries.guava
testImplementation libraries.junit_pioneer testImplementation libraries.junit_pioneer
signature libraries.android_signature signature libraries.android_signature

View File

@ -12,7 +12,7 @@ dependencies {
api project(':opentelemetry-sdk') api project(':opentelemetry-sdk')
implementation project(':opentelemetry-sdk'), implementation project(':opentelemetry-sdk'),
"io.jaegertracing:jaeger-client:0.33.1" libraries.jaeger_client
testImplementation "io.grpc:grpc-testing:${grpcVersion}", testImplementation "io.grpc:grpc-testing:${grpcVersion}",
'com.fasterxml.jackson.core:jackson-databind', 'com.fasterxml.jackson.core:jackson-databind',

View File

@ -13,7 +13,7 @@ import io.opentelemetry.api.trace.Tracer;
import io.opentelemetry.sdk.OpenTelemetrySdk; import io.opentelemetry.sdk.OpenTelemetrySdk;
import io.opentelemetry.sdk.trace.export.SimpleSpanProcessor; import io.opentelemetry.sdk.trace.export.SimpleSpanProcessor;
import io.opentelemetry.sdk.trace.export.SpanExporter; import io.opentelemetry.sdk.trace.export.SpanExporter;
import java.util.concurrent.TimeUnit; import java.time.Duration;
import okhttp3.OkHttpClient; import okhttp3.OkHttpClient;
import okhttp3.Request; import okhttp3.Request;
import okhttp3.Response; import okhttp3.Response;
@ -50,7 +50,7 @@ class JaegerThriftIntegrationTest {
setupJaegerExporter(); setupJaegerExporter();
imitateWork(); imitateWork();
Awaitility.await() Awaitility.await()
.atMost(30, TimeUnit.MINUTES) .atMost(Duration.ofSeconds(30))
.until(JaegerThriftIntegrationTest::assertJaegerHasATrace); .until(JaegerThriftIntegrationTest::assertJaegerHasATrace);
} }

View File

@ -36,10 +36,12 @@ import java.util.Map;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.Mock; import org.mockito.Mock;
import org.mockito.Mockito; import org.mockito.Mockito;
import org.mockito.MockitoAnnotations; import org.mockito.junit.jupiter.MockitoExtension;
@ExtendWith(MockitoExtension.class)
class JaegerThriftSpanExporterTest { class JaegerThriftSpanExporterTest {
private static final String TRACE_ID = "a0000000000000000000000000abc123"; private static final String TRACE_ID = "a0000000000000000000000000abc123";
@ -51,7 +53,6 @@ class JaegerThriftSpanExporterTest {
@BeforeEach @BeforeEach
void beforeEach() { void beforeEach() {
MockitoAnnotations.initMocks(this);
exporter = exporter =
JaegerThriftSpanExporter.builder() JaegerThriftSpanExporter.builder()
.setThriftSender(thriftSender) .setThriftSender(thriftSender)

View File

@ -27,6 +27,10 @@ dependencies {
testImplementation project(':opentelemetry-sdk-testing') testImplementation project(':opentelemetry-sdk-testing')
// Protobuf plugin seems to erroneously use the non-classpath configurations for resolving
// dependencies.
testImplementation enforcedPlatform(boms.jackson)
testRuntime "io.grpc:grpc-netty-shaded:${grpcVersion}" testRuntime "io.grpc:grpc-netty-shaded:${grpcVersion}"
signature "org.codehaus.mojo.signature:java18:1.0@signature" signature "org.codehaus.mojo.signature:java18:1.0@signature"

View File

@ -15,7 +15,7 @@ import io.opentelemetry.api.trace.Tracer;
import io.opentelemetry.sdk.OpenTelemetrySdk; import io.opentelemetry.sdk.OpenTelemetrySdk;
import io.opentelemetry.sdk.trace.export.SimpleSpanProcessor; import io.opentelemetry.sdk.trace.export.SimpleSpanProcessor;
import io.opentelemetry.sdk.trace.export.SpanExporter; import io.opentelemetry.sdk.trace.export.SpanExporter;
import java.util.concurrent.TimeUnit; import java.time.Duration;
import okhttp3.OkHttpClient; import okhttp3.OkHttpClient;
import okhttp3.Request; import okhttp3.Request;
import okhttp3.Response; import okhttp3.Response;
@ -49,7 +49,7 @@ class JaegerIntegrationTest {
setupJaegerExporter(); setupJaegerExporter();
imitateWork(); imitateWork();
Awaitility.await() Awaitility.await()
.atMost(30, TimeUnit.SECONDS) .atMost(Duration.ofSeconds(30))
.until(JaegerIntegrationTest::assertJaegerHaveTrace); .until(JaegerIntegrationTest::assertJaegerHaveTrace);
} }

View File

@ -13,7 +13,8 @@ dependencies {
implementation libraries.prometheus_client implementation libraries.prometheus_client
testImplementation libraries.prometheus_client_common testImplementation libraries.prometheus_client_common,
libraries.guava
signature "org.codehaus.mojo.signature:java18:1.0@signature" signature "org.codehaus.mojo.signature:java18:1.0@signature"
signature libraries.android_signature signature libraries.android_signature

View File

@ -23,16 +23,17 @@ import java.io.StringWriter;
import java.util.Collections; import java.util.Collections;
import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.Mock; import org.mockito.Mock;
import org.mockito.MockitoAnnotations; import org.mockito.junit.jupiter.MockitoExtension;
@ExtendWith(MockitoExtension.class)
class PrometheusCollectorTest { class PrometheusCollectorTest {
@Mock MetricProducer metricProducer; @Mock MetricProducer metricProducer;
PrometheusCollector prometheusCollector; PrometheusCollector prometheusCollector;
@BeforeEach @BeforeEach
void setUp() { void setUp() {
MockitoAnnotations.initMocks(this);
prometheusCollector = prometheusCollector =
PrometheusCollector.builder().setMetricProducer(metricProducer).buildAndRegister(); PrometheusCollector.builder().setMetricProducer(metricProducer).buildAndRegister();
} }

View File

@ -12,7 +12,8 @@ ext.moduleName = "io.opentelemetry.extension.trace.propagation"
dependencies { dependencies {
api project(':opentelemetry-api') api project(':opentelemetry-api')
testImplementation libraries.jaeger_client testImplementation libraries.jaeger_client,
libraries.guava
signature "org.codehaus.mojo.signature:java18:1.0@signature" signature "org.codehaus.mojo.signature:java18:1.0@signature"
signature libraries.android_signature signature libraries.android_signature

View File

@ -24,11 +24,12 @@ import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import javax.annotation.Nullable; import javax.annotation.Nullable;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.Mockito; import org.mockito.Mockito;
import org.mockito.MockitoAnnotations; import org.mockito.junit.jupiter.MockitoExtension;
@ExtendWith(MockitoExtension.class)
class TraceMultiPropagatorTest { class TraceMultiPropagatorTest {
private static final TextMapPropagator PROPAGATOR1 = B3Propagator.getInstance(); private static final TextMapPropagator PROPAGATOR1 = B3Propagator.getInstance();
private static final TextMapPropagator PROPAGATOR2 = private static final TextMapPropagator PROPAGATOR2 =
@ -57,11 +58,6 @@ class TraceMultiPropagatorTest {
TraceFlags.getDefault(), TraceFlags.getDefault(),
TraceState.getDefault())); TraceState.getDefault()));
@BeforeEach
void init() {
MockitoAnnotations.initMocks(this);
}
@Test @Test
void addPropagator_null() { void addPropagator_null() {
assertThrows( assertThrows(

View File

@ -8,7 +8,6 @@ package io.opentelemetry;
import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.ObjectMapper;
import java.time.Duration; import java.time.Duration;
import java.util.concurrent.TimeUnit;
import okhttp3.OkHttpClient; import okhttp3.OkHttpClient;
import okhttp3.Request; import okhttp3.Request;
import okhttp3.Response; import okhttp3.Response;
@ -83,7 +82,7 @@ class JaegerExporterIntegrationTest {
@Test @Test
void testJaegerExampleAppIntegration() { void testJaegerExampleAppIntegration() {
Awaitility.await() Awaitility.await()
.atMost(30, TimeUnit.SECONDS) .atMost(Duration.ofSeconds(30))
.until(JaegerExporterIntegrationTest::assertJaegerHaveTrace); .until(JaegerExporterIntegrationTest::assertJaegerHaveTrace);
} }

View File

@ -23,7 +23,7 @@ dependencies {
project(':opentelemetry-extension-trace-propagators'), project(':opentelemetry-extension-trace-propagators'),
libraries.okhttp, libraries.okhttp,
libraries.slf4jsimple, libraries.slf4jsimple,
"com.sparkjava:spark-core:2.9.2", "com.sparkjava:spark-core:2.9.3",
"com.google.code.gson:gson:2.8.6" "com.google.code.gson:gson:2.8.6"
} }

View File

@ -25,17 +25,16 @@ import io.opentelemetry.sdk.trace.data.SpanData;
import io.opentelemetry.sdk.trace.export.SimpleSpanProcessor; import io.opentelemetry.sdk.trace.export.SimpleSpanProcessor;
import io.opentelemetry.sdk.trace.export.SpanExporter; import io.opentelemetry.sdk.trace.export.SpanExporter;
import java.util.Collection; import java.util.Collection;
import org.junit.Before; import org.junit.jupiter.api.BeforeEach;
import org.junit.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith; import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.ArgumentCaptor; import org.mockito.ArgumentCaptor;
import org.mockito.Captor; import org.mockito.Captor;
import org.mockito.MockitoAnnotations;
import org.mockito.Spy; import org.mockito.Spy;
import org.mockito.junit.jupiter.MockitoExtension; import org.mockito.junit.jupiter.MockitoExtension;
@ExtendWith(MockitoExtension.class) @ExtendWith(MockitoExtension.class)
public class InteroperabilityTest { class InteroperabilityTest {
private static final String NULL_SPAN_ID = "0000000000000000"; private static final String NULL_SPAN_ID = "0000000000000000";
@ -43,16 +42,15 @@ public class InteroperabilityTest {
@Spy private SpanExporter spanExporter; @Spy private SpanExporter spanExporter;
@Before @BeforeEach
public void init() { public void init() {
MockitoAnnotations.initMocks(this);
when(spanExporter.export(any())).thenReturn(CompletableResultCode.ofSuccess()); when(spanExporter.export(any())).thenReturn(CompletableResultCode.ofSuccess());
SpanProcessor spanProcessor = SimpleSpanProcessor.builder(spanExporter).build(); SpanProcessor spanProcessor = SimpleSpanProcessor.builder(spanExporter).build();
OpenTelemetrySdk.getGlobalTracerManagement().addSpanProcessor(spanProcessor); OpenTelemetrySdk.getGlobalTracerManagement().addSpanProcessor(spanProcessor);
} }
@Test @Test
public void testParentChildRelationshipsAreExportedCorrectly() { void testParentChildRelationshipsAreExportedCorrectly() {
Tracer tracer = OpenTelemetry.getGlobalTracer("io.opentelemetry.test.scoped.span.1"); Tracer tracer = OpenTelemetry.getGlobalTracer("io.opentelemetry.test.scoped.span.1");
Span span = tracer.spanBuilder("OpenTelemetrySpan").startSpan(); Span span = tracer.spanBuilder("OpenTelemetrySpan").startSpan();
try (Scope scope = Context.current().with(span).makeCurrent()) { try (Scope scope = Context.current().with(span).makeCurrent()) {
@ -96,7 +94,7 @@ public class InteroperabilityTest {
} }
@Test @Test
public void testParentChildRelationshipsAreExportedCorrectlyForOpenCensusOnly() { void testParentChildRelationshipsAreExportedCorrectlyForOpenCensusOnly() {
io.opencensus.trace.Tracer tracer = Tracing.getTracer(); io.opencensus.trace.Tracer tracer = Tracing.getTracer();
try (io.opencensus.common.Scope scope = try (io.opencensus.common.Scope scope =
tracer tracer

View File

@ -8,7 +8,6 @@ package io.opentelemetry.opentracingshim.testbed.activespanreplacement;
import static io.opentelemetry.api.trace.SpanId.isValid; import static io.opentelemetry.api.trace.SpanId.isValid;
import static io.opentelemetry.opentracingshim.testbed.TestUtils.finishedSpansSize; import static io.opentelemetry.opentracingshim.testbed.TestUtils.finishedSpansSize;
import static io.opentelemetry.opentracingshim.testbed.TestUtils.sleep; import static io.opentelemetry.opentracingshim.testbed.TestUtils.sleep;
import static java.util.concurrent.TimeUnit.SECONDS;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;
import static org.awaitility.Awaitility.await; import static org.awaitility.Awaitility.await;
import static org.hamcrest.core.IsEqual.equalTo; import static org.hamcrest.core.IsEqual.equalTo;
@ -19,6 +18,7 @@ import io.opentelemetry.sdk.trace.data.SpanData;
import io.opentracing.Scope; import io.opentracing.Scope;
import io.opentracing.Span; import io.opentracing.Span;
import io.opentracing.Tracer; import io.opentracing.Tracer;
import java.time.Duration;
import java.util.List; import java.util.List;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
@ -42,7 +42,7 @@ class ActiveSpanReplacementTest {
submitAnotherTask(span); submitAnotherTask(span);
} }
await().atMost(15, SECONDS).until(finishedSpansSize(otelTesting), equalTo(3)); await().atMost(Duration.ofSeconds(15)).until(finishedSpansSize(otelTesting), equalTo(3));
List<SpanData> spans = otelTesting.getSpans(); List<SpanData> spans = otelTesting.getSpans();
assertThat(spans).hasSize(3); assertThat(spans).hasSize(3);

View File

@ -16,9 +16,9 @@ import io.opentelemetry.opentracingshim.OpenTracingShim;
import io.opentelemetry.sdk.testing.junit5.OpenTelemetryExtension; import io.opentelemetry.sdk.testing.junit5.OpenTelemetryExtension;
import io.opentelemetry.sdk.trace.data.SpanData; import io.opentelemetry.sdk.trace.data.SpanData;
import io.opentracing.Tracer; import io.opentracing.Tracer;
import java.time.Duration;
import java.util.List; import java.util.List;
import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.TimeUnit;
import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
@ -49,7 +49,7 @@ class TestClientServerTest {
Client client = new Client(queue, tracer); Client client = new Client(queue, tracer);
client.send(); client.send();
await().atMost(15, TimeUnit.SECONDS).until(finishedSpansSize(otelTesting), equalTo(2)); await().atMost(Duration.ofSeconds(15)).until(finishedSpansSize(otelTesting), equalTo(2));
List<SpanData> finished = otelTesting.getSpans(); List<SpanData> finished = otelTesting.getSpans();
assertThat(finished).hasSize(2); assertThat(finished).hasSize(2);

View File

@ -20,12 +20,12 @@ import io.opentracing.Span;
import io.opentracing.Tracer; import io.opentracing.Tracer;
import io.opentracing.log.Fields; import io.opentracing.log.Fields;
import io.opentracing.tag.Tags; import io.opentracing.tag.Tags;
import java.time.Duration;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.RegisterExtension; import org.junit.jupiter.api.extension.RegisterExtension;
@ -71,7 +71,7 @@ public final class ErrorReportingTest {
} }
}); });
await().atMost(5, TimeUnit.SECONDS).until(finishedSpansSize(otelTesting), equalTo(1)); await().atMost(Duration.ofSeconds(5)).until(finishedSpansSize(otelTesting), equalTo(1));
List<SpanData> spans = otelTesting.getSpans(); List<SpanData> spans = otelTesting.getSpans();
assertThat(spans).hasSize(1); assertThat(spans).hasSize(1);
@ -137,7 +137,7 @@ public final class ErrorReportingTest {
tracer)); tracer));
} }
await().atMost(5, TimeUnit.SECONDS).until(finishedSpansSize(otelTesting), equalTo(1)); await().atMost(Duration.ofSeconds(5)).until(finishedSpansSize(otelTesting), equalTo(1));
List<SpanData> spans = otelTesting.getSpans(); List<SpanData> spans = otelTesting.getSpans();
assertThat(spans).hasSize(1); assertThat(spans).hasSize(1);

View File

@ -16,9 +16,9 @@ import io.opentelemetry.sdk.trace.data.SpanData;
import io.opentracing.Scope; import io.opentracing.Scope;
import io.opentracing.Span; import io.opentracing.Span;
import io.opentracing.Tracer; import io.opentracing.Tracer;
import java.time.Duration;
import java.util.List; import java.util.List;
import java.util.concurrent.CountDownLatch; import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.RegisterExtension; import org.junit.jupiter.api.extension.RegisterExtension;
@ -50,7 +50,7 @@ class MultipleCallbacksTest {
parentDoneLatch.countDown(); parentDoneLatch.countDown();
} }
await().atMost(15, TimeUnit.SECONDS).until(finishedSpansSize(otelTesting), equalTo(4)); await().atMost(Duration.ofSeconds(15)).until(finishedSpansSize(otelTesting), equalTo(4));
List<SpanData> spans = otelTesting.getSpans(); List<SpanData> spans = otelTesting.getSpans();
assertThat(spans).hasSize(4); assertThat(spans).hasSize(4);

View File

@ -18,10 +18,10 @@ import io.opentelemetry.sdk.trace.data.SpanData;
import io.opentracing.Scope; import io.opentracing.Scope;
import io.opentracing.Span; import io.opentracing.Span;
import io.opentracing.Tracer; import io.opentracing.Tracer;
import java.time.Duration;
import java.util.List; import java.util.List;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.RegisterExtension; import org.junit.jupiter.api.extension.RegisterExtension;
@ -39,7 +39,7 @@ public final class NestedCallbacksTest {
Span span = tracer.buildSpan("one").start(); Span span = tracer.buildSpan("one").start();
submitCallbacks(span); submitCallbacks(span);
await().atMost(15, TimeUnit.SECONDS).until(finishedSpansSize(otelTesting), equalTo(1)); await().atMost(Duration.ofSeconds(15)).until(finishedSpansSize(otelTesting), equalTo(1));
List<SpanData> spans = otelTesting.getSpans(); List<SpanData> spans = otelTesting.getSpans();
assertThat(spans).hasSize(1); assertThat(spans).hasSize(1);

View File

@ -5,14 +5,6 @@ plugins {
description = 'Performance Testing Harness' description = 'Performance Testing Harness'
ext.moduleName = "io.opentelemetry.perf-harness" ext.moduleName = "io.opentelemetry.perf-harness"
ext {
opentelemetryVersion = "0.9.1"
grpcVersion = '1.28.0'
protobufVersion = '3.11.4'
protocVersion = protobufVersion
}
dependencies { dependencies {
compile project(':opentelemetry-api'), compile project(':opentelemetry-api'),
project(":opentelemetry-sdk"), project(":opentelemetry-sdk"),
@ -20,8 +12,8 @@ dependencies {
project(":opentelemetry-exporter-otlp"), project(":opentelemetry-exporter-otlp"),
project(":opentelemetry-exporter-logging") project(":opentelemetry-exporter-logging")
compile("io.grpc:grpc-netty-shaded:${grpcVersion}") compile("io.grpc:grpc-netty-shaded")
compile("eu.rekawek.toxiproxy:toxiproxy-java:2.1.3") compile("eu.rekawek.toxiproxy:toxiproxy-java:2.1.4")
implementation libraries.testcontainers implementation libraries.testcontainers
} }

View File

@ -10,6 +10,11 @@ description = 'OpenTelemetry Proto'
ext.moduleName = 'io.opentelemetry.proto' ext.moduleName = 'io.opentelemetry.proto'
dependencies { dependencies {
// Protobuf plugin seems to erroneously use the non-classpath configurations for resolving
// dependencies.
implementation enforcedPlatform(boms.grpc)
implementation enforcedPlatform(boms.protobuf)
api libraries.protobuf, api libraries.protobuf,
libraries.grpc_api, libraries.grpc_api,
libraries.grpc_protobuf, libraries.grpc_protobuf,

View File

@ -20,7 +20,8 @@ dependencies {
libraries.guava, libraries.guava,
platform(boms.guava) platform(boms.guava)
testImplementation 'com.github.tomakehurst:wiremock-jre8:2.26.3' testImplementation 'com.github.tomakehurst:wiremock-jre8:2.27.2',
libraries.junit
signature libraries.android_signature signature libraries.android_signature
} }

View File

@ -10,7 +10,7 @@ import static org.assertj.core.api.Assertions.assertThat;
import static org.awaitility.Awaitility.await; import static org.awaitility.Awaitility.await;
import io.grpc.ManagedChannelBuilder; import io.grpc.ManagedChannelBuilder;
import java.util.concurrent.TimeUnit; import java.time.Duration;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.testcontainers.containers.BindMode; import org.testcontainers.containers.BindMode;
import org.testcontainers.containers.GenericContainer; import org.testcontainers.containers.GenericContainer;
@ -46,7 +46,7 @@ class JaegerRemoteSamplerIntegrationTest {
.build(); .build();
await() await()
.atMost(10, TimeUnit.SECONDS) .atMost(Duration.ofSeconds(10))
.until(samplerIsType(remoteSampler, PerOperationSampler.class)); .until(samplerIsType(remoteSampler, PerOperationSampler.class));
assertThat(remoteSampler.getSampler()).isInstanceOf(PerOperationSampler.class); assertThat(remoteSampler.getSampler()).isInstanceOf(PerOperationSampler.class);
assertThat(remoteSampler.getDescription()).contains("0.33").doesNotContain("150"); assertThat(remoteSampler.getDescription()).contains("0.33").doesNotContain("150");
@ -63,7 +63,7 @@ class JaegerRemoteSamplerIntegrationTest {
.build(); .build();
await() await()
.atMost(10, TimeUnit.SECONDS) .atMost(Duration.ofSeconds(10))
.until(samplerIsType(remoteSampler, RateLimitingSampler.class)); .until(samplerIsType(remoteSampler, RateLimitingSampler.class));
assertThat(remoteSampler.getSampler()).isInstanceOf(RateLimitingSampler.class); assertThat(remoteSampler.getSampler()).isInstanceOf(RateLimitingSampler.class);
assertThat(((RateLimitingSampler) remoteSampler.getSampler()).getMaxTracesPerSecond()) assertThat(((RateLimitingSampler) remoteSampler.getSampler()).getMaxTracesPerSecond())

View File

@ -24,8 +24,8 @@ import io.opentelemetry.sdk.extension.trace.jaeger.proto.api_v2.Sampling.Samplin
import io.opentelemetry.sdk.extension.trace.jaeger.proto.api_v2.SamplingManagerGrpc; import io.opentelemetry.sdk.extension.trace.jaeger.proto.api_v2.SamplingManagerGrpc;
import io.opentelemetry.sdk.trace.samplers.Sampler; import io.opentelemetry.sdk.trace.samplers.Sampler;
import java.io.IOException; import java.io.IOException;
import java.time.Duration;
import java.util.concurrent.Callable; import java.util.concurrent.Callable;
import java.util.concurrent.TimeUnit;
import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
@ -95,7 +95,7 @@ class JaegerRemoteSamplerTest {
.setServiceName(SERVICE_NAME) .setServiceName(SERVICE_NAME)
.build(); .build();
await().atMost(10, TimeUnit.SECONDS).until(samplerIsType(sampler, RateLimitingSampler.class)); await().atMost(Duration.ofSeconds(10)).until(samplerIsType(sampler, RateLimitingSampler.class));
// verify // verify
verify(service).getSamplingStrategy(requestCaptor.capture(), ArgumentMatchers.any()); verify(service).getSamplingStrategy(requestCaptor.capture(), ArgumentMatchers.any());
@ -116,7 +116,7 @@ class JaegerRemoteSamplerTest {
.isEqualTo("JaegerRemoteSampler{TraceIdRatioBased{0.001000}}"); .isEqualTo("JaegerRemoteSampler{TraceIdRatioBased{0.001000}}");
// wait until the sampling strategy is retrieved before exiting test method // wait until the sampling strategy is retrieved before exiting test method
await().atMost(10, TimeUnit.SECONDS).until(samplerIsType(sampler, RateLimitingSampler.class)); await().atMost(Duration.ofSeconds(10)).until(samplerIsType(sampler, RateLimitingSampler.class));
} }
static Callable<Boolean> samplerIsType( static Callable<Boolean> samplerIsType(

View File

@ -10,7 +10,7 @@ ext.moduleName = "io.opentelemetry.sdk.extension.logging"
dependencies { dependencies {
api project(':opentelemetry-sdk') api project(':opentelemetry-sdk')
implementation group: 'com.fasterxml.jackson.core', name: 'jackson-databind', version: '2.10.4' implementation group: 'com.fasterxml.jackson.core', name: 'jackson-databind'
testImplementation libraries.awaitility testImplementation libraries.awaitility
annotationProcessor libraries.auto_value annotationProcessor libraries.auto_value

View File

@ -15,6 +15,7 @@ import io.opentelemetry.sdk.logging.data.LogRecord.Severity;
import io.opentelemetry.sdk.logging.export.BatchLogProcessor; import io.opentelemetry.sdk.logging.export.BatchLogProcessor;
import io.opentelemetry.sdk.logging.util.TestLogExporter; import io.opentelemetry.sdk.logging.util.TestLogExporter;
import io.opentelemetry.sdk.logging.util.TestLogProcessor; import io.opentelemetry.sdk.logging.util.TestLogProcessor;
import java.time.Duration;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
@ -57,7 +58,7 @@ class LogSinkSdkProviderTest {
sink.offer(createLog(Severity.WARN, "test #" + i)); sink.offer(createLog(Severity.WARN, "test #" + i));
} }
// Ensure that more than batch size kicks off a flush // Ensure that more than batch size kicks off a flush
await().atMost(5, TimeUnit.SECONDS).until(() -> exporter.getRecords().size() > 0); await().atMost(Duration.ofSeconds(5)).until(() -> exporter.getRecords().size() > 0);
// Ensure that everything gets through // Ensure that everything gets through
CompletableResultCode result = provider.forceFlush(); CompletableResultCode result = provider.forceFlush();
result.join(1, TimeUnit.SECONDS); result.join(1, TimeUnit.SECONDS);

View File

@ -16,7 +16,8 @@ dependencies {
annotationProcessor libraries.auto_value annotationProcessor libraries.auto_value
testImplementation project(':opentelemetry-sdk-testing') testImplementation project(':opentelemetry-sdk-testing'),
libraries.guava_testlib
signature libraries.android_signature signature libraries.android_signature
} }

View File

@ -20,6 +20,7 @@ import io.opentelemetry.api.trace.attributes.SemanticAttributes;
import io.opentelemetry.sdk.testing.trace.TestSpanData; import io.opentelemetry.sdk.testing.trace.TestSpanData;
import io.opentelemetry.sdk.trace.data.SpanData; import io.opentelemetry.sdk.trace.data.SpanData;
import io.opentelemetry.sdk.trace.data.SpanData.Status; import io.opentelemetry.sdk.trace.data.SpanData.Status;
import org.assertj.core.api.recursive.comparison.RecursiveComparisonConfiguration;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
class DelegatingSpanDataTest { class DelegatingSpanDataTest {
@ -72,7 +73,10 @@ class DelegatingSpanDataTest {
SpanData noopWrapper = new NoOpDelegatingSpanData(spanData); SpanData noopWrapper = new NoOpDelegatingSpanData(spanData);
// Test should always verify delegation is working even when methods are added since it calls // Test should always verify delegation is working even when methods are added since it calls
// each method individually. // each method individually.
assertThat(noopWrapper).isEqualToIgnoringGivenFields(spanData, "delegate"); assertThat(noopWrapper)
.usingRecursiveComparison(
RecursiveComparisonConfiguration.builder().withIgnoredFields("delegate").build())
.isEqualTo(spanData);
} }
@Test @Test

View File

@ -39,7 +39,8 @@ class SpanDataBuilderTest {
@Test @Test
void noOp() { void noOp() {
assertThat(SpanDataBuilder.builder(TEST_SPAN_DATA).build()) assertThat(SpanDataBuilder.builder(TEST_SPAN_DATA).build())
.isEqualToComparingFieldByField(TEST_SPAN_DATA); .usingRecursiveComparison()
.isEqualTo(TEST_SPAN_DATA);
} }
@Test @Test

View File

@ -20,7 +20,8 @@ dependencies {
testCompileOnly libraries.auto_value_annotation testCompileOnly libraries.auto_value_annotation
testImplementation project(':opentelemetry-sdk-testing') testImplementation project(':opentelemetry-sdk-testing')
testImplementation libraries.junit_pioneer testImplementation libraries.junit_pioneer,
libraries.guava_testlib
signature libraries.android_signature signature libraries.android_signature
} }

View File

@ -8,21 +8,16 @@ package io.opentelemetry.sdk.metrics;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;
import io.opentelemetry.sdk.metrics.aggregator.Aggregator; import io.opentelemetry.sdk.metrics.aggregator.Aggregator;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.Mock; import org.mockito.Mock;
import org.mockito.Mockito; import org.mockito.Mockito;
import org.mockito.MockitoAnnotations; import org.mockito.junit.jupiter.MockitoExtension;
/** Unit tests for {@link AbstractBoundInstrument}. */ @ExtendWith(MockitoExtension.class)
class AbstractBoundInstrumentTest { class AbstractBoundInstrumentTest {
@Mock private Aggregator aggregator; @Mock private Aggregator aggregator;
@BeforeEach
void setUp() {
MockitoAnnotations.initMocks(this);
}
@Test @Test
void bindMapped() { void bindMapped() {
TestBoundInstrument testBoundInstrument = new TestBoundInstrument(aggregator); TestBoundInstrument testBoundInstrument = new TestBoundInstrument(aggregator);

View File

@ -20,6 +20,7 @@ import io.opentelemetry.sdk.metrics.data.MetricData;
import io.opentelemetry.sdk.metrics.data.MetricData.DoublePoint; import io.opentelemetry.sdk.metrics.data.MetricData.DoublePoint;
import io.opentelemetry.sdk.resources.Resource; import io.opentelemetry.sdk.resources.Resource;
import java.util.List; import java.util.List;
import org.assertj.core.api.recursive.comparison.RecursiveComparisonConfiguration;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
/** Unit tests for {@link DoubleCounterSdk}. */ /** Unit tests for {@link DoubleCounterSdk}. */
@ -99,7 +100,9 @@ class DoubleCounterSdkTest {
doubleCounter1.add(12.1d); doubleCounter1.add(12.1d);
assertThat(doubleCounter.collectAll().get(0)) assertThat(doubleCounter.collectAll().get(0))
.isEqualToIgnoringGivenFields(doubleCounter1.collectAll().get(0), "name"); .usingRecursiveComparison(
RecursiveComparisonConfiguration.builder().withIgnoredFields("name").build())
.isEqualTo(doubleCounter1.collectAll().get(0));
} }
@Test @Test

View File

@ -20,6 +20,7 @@ import io.opentelemetry.sdk.metrics.data.MetricData;
import io.opentelemetry.sdk.metrics.data.MetricData.DoublePoint; import io.opentelemetry.sdk.metrics.data.MetricData.DoublePoint;
import io.opentelemetry.sdk.resources.Resource; import io.opentelemetry.sdk.resources.Resource;
import java.util.List; import java.util.List;
import org.assertj.core.api.recursive.comparison.RecursiveComparisonConfiguration;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
/** Unit tests for {@link DoubleUpDownCounterSdk}. */ /** Unit tests for {@link DoubleUpDownCounterSdk}. */
@ -103,7 +104,9 @@ class DoubleUpDownCounterSdkTest {
doubleUpDownCounter1.add(12.1d); doubleUpDownCounter1.add(12.1d);
assertThat(doubleUpDownCounter.collectAll().get(0)) assertThat(doubleUpDownCounter.collectAll().get(0))
.isEqualToIgnoringGivenFields(doubleUpDownCounter1.collectAll().get(0), "name"); .usingRecursiveComparison(
RecursiveComparisonConfiguration.builder().withIgnoredFields("name").build())
.isEqualTo(doubleUpDownCounter1.collectAll().get(0));
} }
@Test @Test

View File

@ -23,6 +23,7 @@ import io.opentelemetry.sdk.resources.Resource;
import java.util.Arrays; import java.util.Arrays;
import java.util.Collections; import java.util.Collections;
import java.util.List; import java.util.List;
import org.assertj.core.api.recursive.comparison.RecursiveComparisonConfiguration;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
/** Unit tests for {@link DoubleValueRecorderSdk}. */ /** Unit tests for {@link DoubleValueRecorderSdk}. */
@ -138,7 +139,9 @@ class DoubleValueRecorderSdkTest {
doubleMeasure1.record(12.1d); doubleMeasure1.record(12.1d);
assertThat(doubleMeasure.collectAll().get(0)) assertThat(doubleMeasure.collectAll().get(0))
.isEqualToIgnoringGivenFields(doubleMeasure1.collectAll().get(0), "name"); .usingRecursiveComparison(
RecursiveComparisonConfiguration.builder().withIgnoredFields("name").build())
.isEqualTo(doubleMeasure1.collectAll().get(0));
} }
@Test @Test

View File

@ -21,6 +21,7 @@ import io.opentelemetry.sdk.metrics.data.MetricData;
import io.opentelemetry.sdk.metrics.data.MetricData.LongPoint; import io.opentelemetry.sdk.metrics.data.MetricData.LongPoint;
import io.opentelemetry.sdk.resources.Resource; import io.opentelemetry.sdk.resources.Resource;
import java.util.List; import java.util.List;
import org.assertj.core.api.recursive.comparison.RecursiveComparisonConfiguration;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
/** Unit tests for {@link LongCounterSdk}. */ /** Unit tests for {@link LongCounterSdk}. */
@ -119,7 +120,9 @@ class LongCounterSdkTest {
longCounter1.add(12); longCounter1.add(12);
assertThat(longCounter.collectAll().get(0)) assertThat(longCounter.collectAll().get(0))
.isEqualToIgnoringGivenFields(longCounter1.collectAll().get(0), "name"); .usingRecursiveComparison(
RecursiveComparisonConfiguration.builder().withIgnoredFields("name").build())
.isEqualTo(longCounter1.collectAll().get(0));
} }
@Test @Test

View File

@ -20,6 +20,7 @@ import io.opentelemetry.sdk.metrics.data.MetricData;
import io.opentelemetry.sdk.metrics.data.MetricData.LongPoint; import io.opentelemetry.sdk.metrics.data.MetricData.LongPoint;
import io.opentelemetry.sdk.resources.Resource; import io.opentelemetry.sdk.resources.Resource;
import java.util.List; import java.util.List;
import org.assertj.core.api.recursive.comparison.RecursiveComparisonConfiguration;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
/** Unit tests for {@link LongUpDownCounterSdk}. */ /** Unit tests for {@link LongUpDownCounterSdk}. */
@ -100,7 +101,9 @@ class LongUpDownCounterSdkTest {
longUpDownCounter1.add(12); longUpDownCounter1.add(12);
assertThat(longUpDownCounter.collectAll().get(0)) assertThat(longUpDownCounter.collectAll().get(0))
.isEqualToIgnoringGivenFields(longUpDownCounter1.collectAll().get(0), "name"); .usingRecursiveComparison(
RecursiveComparisonConfiguration.builder().withIgnoredFields("name").build())
.isEqualTo(longUpDownCounter1.collectAll().get(0));
} }
@Test @Test

View File

@ -23,6 +23,7 @@ import io.opentelemetry.sdk.resources.Resource;
import java.util.Arrays; import java.util.Arrays;
import java.util.Collections; import java.util.Collections;
import java.util.List; import java.util.List;
import org.assertj.core.api.recursive.comparison.RecursiveComparisonConfiguration;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
/** Unit tests for {@link LongValueRecorderSdk}. */ /** Unit tests for {@link LongValueRecorderSdk}. */
@ -136,7 +137,9 @@ class LongValueRecorderSdkTest {
longMeasure1.record(12); longMeasure1.record(12);
assertThat(longMeasure.collectAll().get(0)) assertThat(longMeasure.collectAll().get(0))
.isEqualToIgnoringGivenFields(longMeasure1.collectAll().get(0), "name"); .usingRecursiveComparison(
RecursiveComparisonConfiguration.builder().withIgnoredFields("name").build())
.isEqualTo(longMeasure1.collectAll().get(0));
} }
@Test @Test

View File

@ -28,11 +28,15 @@ import javax.annotation.concurrent.GuardedBy;
import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.Timeout; import org.junit.jupiter.api.Timeout;
import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.Mock; import org.mockito.Mock;
import org.mockito.Mockito; import org.mockito.Mockito;
import org.mockito.MockitoAnnotations; import org.mockito.junit.jupiter.MockitoExtension;
import org.mockito.junit.jupiter.MockitoSettings;
import org.mockito.quality.Strictness;
/** Unit tests for {@link IntervalMetricReader}. */ @ExtendWith(MockitoExtension.class)
@MockitoSettings(strictness = Strictness.LENIENT)
class IntervalMetricReaderTest { class IntervalMetricReaderTest {
private static final List<Point> LONG_POINT_LIST = private static final List<Point> LONG_POINT_LIST =
Collections.singletonList(LongPoint.create(1000, 3000, Labels.empty(), 1234567)); Collections.singletonList(LongPoint.create(1000, 3000, Labels.empty(), 1234567));
@ -51,7 +55,6 @@ class IntervalMetricReaderTest {
@BeforeEach @BeforeEach
void setup() { void setup() {
MockitoAnnotations.initMocks(this);
when(metricProducer.collectAllMetrics()).thenReturn(Collections.singletonList(METRIC_DATA)); when(metricProducer.collectAllMetrics()).thenReturn(Collections.singletonList(METRIC_DATA));
} }

View File

@ -14,5 +14,7 @@ dependencies {
compileOnly libraries.junit compileOnly libraries.junit
compileOnly libraries.junit_jupiter_api compileOnly libraries.junit_jupiter_api
testImplementation libraries.junit
annotationProcessor libraries.auto_value annotationProcessor libraries.auto_value
} }

View File

@ -44,10 +44,12 @@ public class OpenTelemetryRuleTest {
tracer.spanBuilder("test").startSpan().end(); tracer.spanBuilder("test").startSpan().end();
assertThat(otelTesting.getSpans()) assertThat(otelTesting.getSpans())
.hasOnlyOneElementSatisfying(span -> assertThat(span.getName()).isEqualTo("test")); .singleElement()
.satisfies(span -> assertThat(span.getName()).isEqualTo("test"));
// Spans cleared between tests, not when retrieving // Spans cleared between tests, not when retrieving
assertThat(otelTesting.getSpans()) assertThat(otelTesting.getSpans())
.hasOnlyOneElementSatisfying(span -> assertThat(span.getName()).isEqualTo("test")); .singleElement()
.satisfies(span -> assertThat(span.getName()).isEqualTo("test"));
} }
// We have two tests to verify spans get cleared up between tests. // We have two tests to verify spans get cleared up between tests.
@ -56,9 +58,11 @@ public class OpenTelemetryRuleTest {
tracer.spanBuilder("test").startSpan().end(); tracer.spanBuilder("test").startSpan().end();
assertThat(otelTesting.getSpans()) assertThat(otelTesting.getSpans())
.hasOnlyOneElementSatisfying(span -> assertThat(span.getName()).isEqualTo("test")); .singleElement()
.satisfies(span -> assertThat(span.getName()).isEqualTo("test"));
// Spans cleared between tests, not when retrieving // Spans cleared between tests, not when retrieving
assertThat(otelTesting.getSpans()) assertThat(otelTesting.getSpans())
.hasOnlyOneElementSatisfying(span -> assertThat(span.getName()).isEqualTo("test")); .singleElement()
.satisfies(span -> assertThat(span.getName()).isEqualTo("test"));
} }
} }

View File

@ -45,10 +45,12 @@ class OpenTelemetryExtensionTest {
tracer.spanBuilder("test").startSpan().end(); tracer.spanBuilder("test").startSpan().end();
assertThat(otelTesting.getSpans()) assertThat(otelTesting.getSpans())
.hasOnlyOneElementSatisfying(span -> assertThat(span.getName()).isEqualTo("test")); .singleElement()
.satisfies(span -> assertThat(span.getName()).isEqualTo("test"));
// Spans cleared between tests, not when retrieving // Spans cleared between tests, not when retrieving
assertThat(otelTesting.getSpans()) assertThat(otelTesting.getSpans())
.hasOnlyOneElementSatisfying(span -> assertThat(span.getName()).isEqualTo("test")); .singleElement()
.satisfies(span -> assertThat(span.getName()).isEqualTo("test"));
} }
// We have two tests to verify spans get cleared up between tests. // We have two tests to verify spans get cleared up between tests.
@ -57,10 +59,12 @@ class OpenTelemetryExtensionTest {
tracer.spanBuilder("test").startSpan().end(); tracer.spanBuilder("test").startSpan().end();
assertThat(otelTesting.getSpans()) assertThat(otelTesting.getSpans())
.hasOnlyOneElementSatisfying(span -> assertThat(span.getName()).isEqualTo("test")); .singleElement()
.satisfies(span -> assertThat(span.getName()).isEqualTo("test"));
// Spans cleared between tests, not when retrieving // Spans cleared between tests, not when retrieving
assertThat(otelTesting.getSpans()) assertThat(otelTesting.getSpans())
.hasOnlyOneElementSatisfying(span -> assertThat(span.getName()).isEqualTo("test")); .singleElement()
.satisfies(span -> assertThat(span.getName()).isEqualTo("test"));
} }
@Test @Test

View File

@ -18,9 +18,14 @@ import java.util.Arrays;
import java.util.Collections; import java.util.Collections;
import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.Mock; import org.mockito.Mock;
import org.mockito.MockitoAnnotations; import org.mockito.junit.jupiter.MockitoExtension;
import org.mockito.junit.jupiter.MockitoSettings;
import org.mockito.quality.Strictness;
@ExtendWith(MockitoExtension.class)
@MockitoSettings(strictness = Strictness.LENIENT)
class MultiSpanProcessorTest { class MultiSpanProcessorTest {
@Mock private SpanProcessor spanProcessor1; @Mock private SpanProcessor spanProcessor1;
@Mock private SpanProcessor spanProcessor2; @Mock private SpanProcessor spanProcessor2;
@ -29,7 +34,6 @@ class MultiSpanProcessorTest {
@BeforeEach @BeforeEach
void setUp() { void setUp() {
MockitoAnnotations.initMocks(this);
when(spanProcessor1.isStartRequired()).thenReturn(true); when(spanProcessor1.isStartRequired()).thenReturn(true);
when(spanProcessor1.isEndRequired()).thenReturn(true); when(spanProcessor1.isEndRequired()).thenReturn(true);
when(spanProcessor1.forceFlush()).thenReturn(CompletableResultCode.ofSuccess()); when(spanProcessor1.forceFlush()).thenReturn(CompletableResultCode.ofSuccess());

View File

@ -8,21 +8,16 @@ package io.opentelemetry.sdk.trace;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;
import io.opentelemetry.context.Context; import io.opentelemetry.context.Context;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.Mock; import org.mockito.Mock;
import org.mockito.MockitoAnnotations; import org.mockito.junit.jupiter.MockitoExtension;
/** Unit tests for {@link NoopSpanProcessorTest}. */ @ExtendWith(MockitoExtension.class)
class NoopSpanProcessorTest { class NoopSpanProcessorTest {
@Mock private ReadableSpan readableSpan; @Mock private ReadableSpan readableSpan;
@Mock private ReadWriteSpan readWriteSpan; @Mock private ReadWriteSpan readWriteSpan;
@BeforeEach
void setUp() {
MockitoAnnotations.initMocks(this);
}
@Test @Test
void noCrash() { void noCrash() {
SpanProcessor noopSpanProcessor = NoopSpanProcessor.getInstance(); SpanProcessor noopSpanProcessor = NoopSpanProcessor.getInstance();

View File

@ -53,11 +53,13 @@ import java.util.concurrent.TimeUnit;
import javax.annotation.Nullable; import javax.annotation.Nullable;
import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.Mock; import org.mockito.Mock;
import org.mockito.Mockito; import org.mockito.Mockito;
import org.mockito.MockitoAnnotations; import org.mockito.junit.jupiter.MockitoExtension;
@SuppressWarnings({"rawtypes", "unchecked"}) @SuppressWarnings({"rawtypes", "unchecked"})
@ExtendWith(MockitoExtension.class)
class RecordEventsReadableSpanTest { class RecordEventsReadableSpanTest {
private static final String SPAN_NAME = "MySpanName"; private static final String SPAN_NAME = "MySpanName";
private static final String SPAN_NEW_NAME = "NewName"; private static final String SPAN_NEW_NAME = "NewName";
@ -84,7 +86,6 @@ class RecordEventsReadableSpanTest {
@BeforeEach @BeforeEach
void setUp() { void setUp() {
MockitoAnnotations.initMocks(this);
attributes.put(stringKey("MyStringAttributeKey"), "MyStringAttributeValue"); attributes.put(stringKey("MyStringAttributeKey"), "MyStringAttributeValue");
attributes.put(longKey("MyLongAttributeKey"), 123L); attributes.put(longKey("MyLongAttributeKey"), 123L);
attributes.put(booleanKey("MyBooleanAttributeKey"), false); attributes.put(booleanKey("MyBooleanAttributeKey"), false);

View File

@ -18,15 +18,16 @@ import io.opentelemetry.sdk.trace.export.BatchSpanProcessor;
import io.opentelemetry.sdk.trace.export.SpanExporter; import io.opentelemetry.sdk.trace.export.SpanExporter;
import java.util.Collection; import java.util.Collection;
import java.util.concurrent.atomic.AtomicLong; import java.util.concurrent.atomic.AtomicLong;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.Mock; import org.mockito.Mock;
import org.mockito.MockitoAnnotations; import org.mockito.junit.jupiter.MockitoExtension;
/** Unit tests for {@link TracerSdk}. */ /** Unit tests for {@link TracerSdk}. */
// Need to suppress warnings for MustBeClosed because Android 14 does not support // Need to suppress warnings for MustBeClosed because Android 14 does not support
// try-with-resources. // try-with-resources.
@SuppressWarnings("MustBeClosedChecker") @SuppressWarnings("MustBeClosedChecker")
@ExtendWith(MockitoExtension.class)
class TracerSdkTest { class TracerSdkTest {
private static final String SPAN_NAME = "span_name"; private static final String SPAN_NAME = "span_name";
@ -43,11 +44,6 @@ class TracerSdkTest {
.build() .build()
.get(INSTRUMENTATION_LIBRARY_NAME, INSTRUMENTATION_LIBRARY_VERSION); .get(INSTRUMENTATION_LIBRARY_NAME, INSTRUMENTATION_LIBRARY_VERSION);
@BeforeEach
void setUp() {
MockitoAnnotations.initMocks(this);
}
@Test @Test
void defaultSpanBuilder() { void defaultSpanBuilder() {
assertThat(tracer.spanBuilder(SPAN_NAME)).isInstanceOf(SpanBuilderSdk.class); assertThat(tracer.spanBuilder(SPAN_NAME)).isInstanceOf(SpanBuilderSdk.class);

View File

@ -32,14 +32,14 @@ import java.util.concurrent.atomic.AtomicBoolean;
import javax.annotation.Nullable; import javax.annotation.Nullable;
import javax.annotation.concurrent.GuardedBy; import javax.annotation.concurrent.GuardedBy;
import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.Timeout; import org.junit.jupiter.api.Timeout;
import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.ArgumentMatchers; import org.mockito.ArgumentMatchers;
import org.mockito.Mock; import org.mockito.Mock;
import org.mockito.MockitoAnnotations; import org.mockito.junit.jupiter.MockitoExtension;
/** Unit tests for {@link BatchSpanProcessor}. */ @ExtendWith(MockitoExtension.class)
class BatchSpanProcessorTest { class BatchSpanProcessorTest {
private static final String SPAN_NAME_1 = "MySpanName/1"; private static final String SPAN_NAME_1 = "MySpanName/1";
@ -50,11 +50,6 @@ class BatchSpanProcessorTest {
private final BlockingSpanExporter blockingSpanExporter = new BlockingSpanExporter(); private final BlockingSpanExporter blockingSpanExporter = new BlockingSpanExporter();
@Mock private SpanExporter mockServiceHandler; @Mock private SpanExporter mockServiceHandler;
@BeforeEach
void setup() {
MockitoAnnotations.initMocks(this);
}
@AfterEach @AfterEach
void cleanup() { void cleanup() {
tracerSdkFactory.shutdown(); tracerSdkFactory.shutdown();

View File

@ -17,10 +17,10 @@ import io.opentelemetry.context.Scope;
import io.opentelemetry.sdk.testing.junit5.OpenTelemetryExtension; import io.opentelemetry.sdk.testing.junit5.OpenTelemetryExtension;
import io.opentelemetry.sdk.trace.data.SpanData; import io.opentelemetry.sdk.trace.data.SpanData;
import io.opentelemetry.sdk.trace.testbed.TestUtils; import io.opentelemetry.sdk.trace.testbed.TestUtils;
import java.time.Duration;
import java.util.List; import java.util.List;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.RegisterExtension; import org.junit.jupiter.api.extension.RegisterExtension;
@ -44,7 +44,7 @@ class ActiveSpanReplacementTest {
} }
await() await()
.atMost(15, TimeUnit.SECONDS) .atMost(Duration.ofSeconds(15))
.until(TestUtils.finishedSpansSize(otelTesting), equalTo(3)); .until(TestUtils.finishedSpansSize(otelTesting), equalTo(3));
List<SpanData> spans = otelTesting.getSpans(); List<SpanData> spans = otelTesting.getSpans();

View File

@ -15,9 +15,9 @@ import io.opentelemetry.api.trace.Tracer;
import io.opentelemetry.sdk.testing.junit5.OpenTelemetryExtension; import io.opentelemetry.sdk.testing.junit5.OpenTelemetryExtension;
import io.opentelemetry.sdk.trace.data.SpanData; import io.opentelemetry.sdk.trace.data.SpanData;
import io.opentelemetry.sdk.trace.testbed.TestUtils; import io.opentelemetry.sdk.trace.testbed.TestUtils;
import java.time.Duration;
import java.util.List; import java.util.List;
import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.TimeUnit;
import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
@ -51,7 +51,7 @@ class TestClientServerTest {
client.send(); client.send();
await() await()
.atMost(15, TimeUnit.SECONDS) .atMost(Duration.ofSeconds(15))
.until(TestUtils.finishedSpansSize(otelTesting), equalTo(2)); .until(TestUtils.finishedSpansSize(otelTesting), equalTo(2));
List<SpanData> finished = otelTesting.getSpans(); List<SpanData> finished = otelTesting.getSpans();

View File

@ -17,10 +17,10 @@ import io.opentelemetry.sdk.testing.junit5.OpenTelemetryExtension;
import io.opentelemetry.sdk.trace.data.SpanData; import io.opentelemetry.sdk.trace.data.SpanData;
import io.opentelemetry.sdk.trace.data.SpanData.Event; import io.opentelemetry.sdk.trace.data.SpanData.Event;
import io.opentelemetry.sdk.trace.testbed.TestUtils; import io.opentelemetry.sdk.trace.testbed.TestUtils;
import java.time.Duration;
import java.util.List; import java.util.List;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.RegisterExtension; import org.junit.jupiter.api.extension.RegisterExtension;
@ -68,7 +68,9 @@ public final class ErrorReportingTest {
} }
}); });
await().atMost(5, TimeUnit.SECONDS).until(TestUtils.finishedSpansSize(otelTesting), equalTo(1)); await()
.atMost(Duration.ofSeconds(5))
.until(TestUtils.finishedSpansSize(otelTesting), equalTo(1));
List<SpanData> spans = otelTesting.getSpans(); List<SpanData> spans = otelTesting.getSpans();
assertThat(spans).hasSize(1); assertThat(spans).hasSize(1);
@ -127,7 +129,9 @@ public final class ErrorReportingTest {
tracer)); tracer));
} }
await().atMost(5, TimeUnit.SECONDS).until(TestUtils.finishedSpansSize(otelTesting), equalTo(1)); await()
.atMost(Duration.ofSeconds(5))
.until(TestUtils.finishedSpansSize(otelTesting), equalTo(1));
List<SpanData> spans = otelTesting.getSpans(); List<SpanData> spans = otelTesting.getSpans();
assertThat(spans).hasSize(1); assertThat(spans).hasSize(1);

View File

@ -15,9 +15,9 @@ import io.opentelemetry.context.Scope;
import io.opentelemetry.sdk.testing.junit5.OpenTelemetryExtension; import io.opentelemetry.sdk.testing.junit5.OpenTelemetryExtension;
import io.opentelemetry.sdk.trace.data.SpanData; import io.opentelemetry.sdk.trace.data.SpanData;
import io.opentelemetry.sdk.trace.testbed.TestUtils; import io.opentelemetry.sdk.trace.testbed.TestUtils;
import java.time.Duration;
import java.util.List; import java.util.List;
import java.util.concurrent.CountDownLatch; import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.RegisterExtension; import org.junit.jupiter.api.extension.RegisterExtension;
@ -51,7 +51,7 @@ class MultipleCallbacksTest {
} }
await() await()
.atMost(15, TimeUnit.SECONDS) .atMost(Duration.ofSeconds(15))
.until(TestUtils.finishedSpansSize(otelTesting), equalTo(4)); .until(TestUtils.finishedSpansSize(otelTesting), equalTo(4));
List<SpanData> spans = otelTesting.getSpans(); List<SpanData> spans = otelTesting.getSpans();

View File

@ -17,10 +17,10 @@ import io.opentelemetry.context.Scope;
import io.opentelemetry.sdk.testing.junit5.OpenTelemetryExtension; import io.opentelemetry.sdk.testing.junit5.OpenTelemetryExtension;
import io.opentelemetry.sdk.trace.data.SpanData; import io.opentelemetry.sdk.trace.data.SpanData;
import io.opentelemetry.sdk.trace.testbed.TestUtils; import io.opentelemetry.sdk.trace.testbed.TestUtils;
import java.time.Duration;
import java.util.List; import java.util.List;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.RegisterExtension; import org.junit.jupiter.api.extension.RegisterExtension;
@ -40,7 +40,7 @@ public final class NestedCallbacksTest {
submitCallbacks(span); submitCallbacks(span);
await() await()
.atMost(15, TimeUnit.SECONDS) .atMost(Duration.ofSeconds(15))
.until(TestUtils.finishedSpansSize(otelTesting), equalTo(1)); .until(TestUtils.finishedSpansSize(otelTesting), equalTo(1));
List<SpanData> spans = otelTesting.getSpans(); List<SpanData> spans = otelTesting.getSpans();

View File

@ -1,16 +1,16 @@
pluginManagement { pluginManagement {
plugins { plugins {
id "com.diffplug.spotless" version "5.7.0" id "com.diffplug.spotless" version "5.8.2"
id "com.github.ben-manes.versions" version "0.20.0" id "com.github.ben-manes.versions" version "0.36.0"
id "com.github.kt3k.coveralls" version "2.0.1" id "com.github.kt3k.coveralls" version "2.0.1"
id "com.google.protobuf" version "0.8.8" id "com.google.protobuf" version "0.8.14"
id "com.jfrog.artifactory" version "4.13.0" id "com.jfrog.artifactory" version "4.18.0"
id "com.jfrog.bintray" version "1.8.4" // Need *specific* version. id "com.jfrog.bintray" version "1.8.5"
id "io.morethan.jmhreport" version "0.9.0" id "io.morethan.jmhreport" version "0.9.0"
id "me.champeau.gradle.jmh" version "0.5.0" id "me.champeau.gradle.jmh" version "0.5.2"
id "nebula.release" version "15.1.0" id "nebula.release" version "15.3.0"
id "net.ltgt.errorprone" version "1.3.0" id "net.ltgt.errorprone" version "1.3.0"
id "org.jetbrains.kotlin.jvm" version "1.4.10" id "org.jetbrains.kotlin.jvm" version "1.4.20"
id "org.unbroken-dome.test-sets" version "3.0.1" id "org.unbroken-dome.test-sets" version "3.0.1"
id "ru.vyarus.animalsniffer" version "1.5.2" id "ru.vyarus.animalsniffer" version "1.5.2"
} }