|
5 | 5 |
|
6 | 6 | package io.opentelemetry.instrumentation.failsafe.v3_0; |
7 | 7 |
|
8 | | -import static io.opentelemetry.api.common.AttributeKey.stringKey; |
9 | | -import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.equalTo; |
10 | 8 | import static org.mockito.Mockito.mock; |
11 | 9 | import static org.mockito.Mockito.when; |
12 | 10 |
|
|
19 | 17 | import io.opentelemetry.instrumentation.failsafe.v3_0.internal.RetryPolicyEventListenerBuilders; |
20 | 18 | import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension; |
21 | 19 | import io.opentelemetry.instrumentation.testing.junit.LibraryInstrumentationExtension; |
22 | | -import io.opentelemetry.sdk.testing.assertj.LongPointAssert; |
23 | 20 | import java.util.Objects; |
24 | | -import java.util.function.Consumer; |
25 | 21 | import org.junit.jupiter.api.Test; |
26 | 22 | import org.junit.jupiter.api.extension.RegisterExtension; |
27 | 23 |
|
@@ -116,14 +112,4 @@ void createInstrumentedSuccessListener() throws Throwable { |
116 | 112 | .hasPointsSatisfying( |
117 | 113 | buildRetryPolicyAssertion(1, retryPolicyName, "success")))); |
118 | 114 | } |
119 | | - |
120 | | - private static Consumer<LongPointAssert> buildRetryPolicyAssertion( |
121 | | - long expectedValue, String expectedOutcomeValue) { |
122 | | - return longSumAssert -> |
123 | | - longSumAssert |
124 | | - .hasValue(expectedValue) |
125 | | - .hasAttributesSatisfyingExactly( |
126 | | - equalTo(stringKey("failsafe.retry_policy.name"), "testing"), |
127 | | - equalTo(stringKey("failsafe.retry_policy.outcome"), expectedOutcomeValue)); |
128 | | - } |
129 | 115 | } |
0 commit comments