Skip to content

Commit 7b59479

Browse files
committed
Fix spotless: use static imports for SemconvStability methods
Signed-off-by: Gregor Zeitlinger <gregor.zeitlinger@grafana.com>
1 parent 83ffb47 commit 7b59479

5 files changed

Lines changed: 24 additions & 21 deletions

File tree

instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/rpc/RpcAttributesGetter.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -74,8 +74,8 @@ default String getRpcMethod(REQUEST request) {
7474
*
7575
* <p>This method should return {@code null} if there was no error.
7676
*
77-
* <p>If this method returns {@code null}, the exception class name
78-
* will be used as error type if one was thrown.
77+
* <p>If this method returns {@code null}, the exception class name will be used as error type if
78+
* one was thrown.
7979
*
8080
* <p>The cardinality of the error type should be low. The instrumentations implementing this
8181
* method are recommended to document the custom values they support.

instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/rpc/RpcCommonAttributesExtractor.java

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

66
package io.opentelemetry.instrumentation.api.incubator.semconv.rpc;
77

8+
import static io.opentelemetry.instrumentation.api.internal.SemconvStability.emitOldRpcSemconv;
9+
import static io.opentelemetry.instrumentation.api.internal.SemconvStability.emitStableRpcSemconv;
810
import static io.opentelemetry.semconv.ErrorAttributes.ERROR_TYPE;
911

1012
import io.opentelemetry.api.common.AttributeKey;
1113
import io.opentelemetry.api.common.AttributesBuilder;
1214
import io.opentelemetry.context.Context;
1315
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
14-
import io.opentelemetry.instrumentation.api.internal.SemconvStability;
1516
import javax.annotation.Nullable;
1617

1718
abstract class RpcCommonAttributesExtractor<REQUEST, RESPONSE>
@@ -38,15 +39,15 @@ abstract class RpcCommonAttributesExtractor<REQUEST, RESPONSE>
3839
@Override
3940
public final void onStart(AttributesBuilder attributes, Context parentContext, REQUEST request) {
4041

41-
if (SemconvStability.emitStableRpcSemconv()) {
42+
if (emitStableRpcSemconv()) {
4243
attributes.put(RPC_SYSTEM_NAME, getter.getRpcSystemName(request));
4344
attributes.put(RPC_METHOD, getter.getRpcMethod(request));
4445
}
4546

46-
if (SemconvStability.emitOldRpcSemconv()) {
47+
if (emitOldRpcSemconv()) {
4748
attributes.put(RPC_SYSTEM, getter.getSystem(request));
4849
attributes.put(RPC_SERVICE, getter.getService(request));
49-
if (!SemconvStability.emitStableRpcSemconv()) {
50+
if (!emitStableRpcSemconv()) {
5051
// only set old rpc.method on spans when there's no clash with stable rpc.method
5152
attributes.put(RPC_METHOD, getter.getMethod(request));
5253
}
@@ -60,7 +61,7 @@ public final void onEnd(
6061
REQUEST request,
6162
@Nullable RESPONSE response,
6263
@Nullable Throwable error) {
63-
if (SemconvStability.emitStableRpcSemconv()) {
64+
if (emitStableRpcSemconv()) {
6465
String errorType = getter.getErrorType(request, response, error);
6566
// fall back to exception class name
6667
if (errorType == null && error != null) {

instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/rpc/RpcSpanNameExtractor.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,9 @@
55

66
package io.opentelemetry.instrumentation.api.incubator.semconv.rpc;
77

8+
import static io.opentelemetry.instrumentation.api.internal.SemconvStability.emitStableRpcSemconv;
9+
810
import io.opentelemetry.instrumentation.api.instrumenter.SpanNameExtractor;
9-
import io.opentelemetry.instrumentation.api.internal.SemconvStability;
1011

1112
/** A {@link SpanNameExtractor} for RPC requests. */
1213
public final class RpcSpanNameExtractor<REQUEST> implements SpanNameExtractor<REQUEST> {
@@ -29,7 +30,7 @@ private RpcSpanNameExtractor(RpcAttributesGetter<REQUEST, ?> getter) {
2930
@SuppressWarnings("deprecation") // for getMethod()
3031
@Override
3132
public String extract(REQUEST request) {
32-
if (SemconvStability.emitStableRpcSemconv()) {
33+
if (emitStableRpcSemconv()) {
3334
String method = getter.getRpcMethod(request);
3435
if (method != null) {
3536
return method;

instrumentation-api-incubator/src/test/java/io/opentelemetry/instrumentation/api/incubator/semconv/rpc/RpcAttributesExtractorTest.java

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

66
package io.opentelemetry.instrumentation.api.incubator.semconv.rpc;
77

8+
import static io.opentelemetry.instrumentation.api.internal.SemconvStability.emitOldRpcSemconv;
9+
import static io.opentelemetry.instrumentation.api.internal.SemconvStability.emitStableRpcSemconv;
810
import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.assertThat;
911
import static io.opentelemetry.semconv.ErrorAttributes.ERROR_TYPE;
1012
import static org.assertj.core.api.Assertions.entry;
@@ -14,7 +16,6 @@
1416
import io.opentelemetry.api.common.AttributesBuilder;
1517
import io.opentelemetry.context.Context;
1618
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
17-
import io.opentelemetry.instrumentation.api.internal.SemconvStability;
1819
import io.opentelemetry.semconv.incubating.RpcIncubatingAttributes;
1920
import java.util.ArrayList;
2021
import java.util.HashMap;
@@ -102,15 +103,15 @@ private static void testExtractor(AttributesExtractor<Map<String, String>, Void>
102103
// Build expected entries list based on semconv mode
103104
List<Map.Entry<? extends AttributeKey<?>, ?>> expectedEntries = new ArrayList<>();
104105

105-
if (SemconvStability.emitStableRpcSemconv()) {
106+
if (emitStableRpcSemconv()) {
106107
expectedEntries.add(entry(RPC_SYSTEM_NAME, "test"));
107108
expectedEntries.add(entry(RPC_METHOD, "my.Service/Method"));
108109
}
109110

110-
if (SemconvStability.emitOldRpcSemconv()) {
111+
if (emitOldRpcSemconv()) {
111112
expectedEntries.add(entry(RPC_SYSTEM, "test"));
112113
expectedEntries.add(entry(RPC_SERVICE, "my.Service"));
113-
if (!SemconvStability.emitStableRpcSemconv()) {
114+
if (!emitStableRpcSemconv()) {
114115
expectedEntries.add(entry(RPC_METHOD, "Method"));
115116
}
116117
}
@@ -140,7 +141,7 @@ void shouldExtractErrorType_getter() {
140141
extractor.onStart(attributes, context, request);
141142
extractor.onEnd(attributes, context, request, null, null);
142143

143-
if (SemconvStability.emitStableRpcSemconv()) {
144+
if (emitStableRpcSemconv()) {
144145
assertThat(attributes.build()).containsEntry(ERROR_TYPE, "CANCELLED");
145146
}
146147
}
@@ -159,7 +160,7 @@ void shouldExtractErrorType_exceptionClassName() {
159160
extractor.onStart(attributes, context, request);
160161
extractor.onEnd(attributes, context, request, null, new IllegalArgumentException());
161162

162-
if (SemconvStability.emitStableRpcSemconv()) {
163+
if (emitStableRpcSemconv()) {
163164
assertThat(attributes.build())
164165
.containsEntry(ERROR_TYPE, "java.lang.IllegalArgumentException");
165166
}
@@ -179,7 +180,7 @@ void shouldNotExtractErrorType_noError() {
179180
extractor.onStart(attributes, context, request);
180181
extractor.onEnd(attributes, context, request, null, null);
181182

182-
if (SemconvStability.emitStableRpcSemconv()) {
183+
if (emitStableRpcSemconv()) {
183184
assertThat(attributes.build()).doesNotContainKey(ERROR_TYPE);
184185
}
185186
}

instrumentation-api-incubator/src/test/java/io/opentelemetry/instrumentation/api/incubator/semconv/rpc/RpcSpanNameExtractorTest.java

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

66
package io.opentelemetry.instrumentation.api.incubator.semconv.rpc;
77

8+
import static io.opentelemetry.instrumentation.api.internal.SemconvStability.emitStableRpcSemconv;
89
import static org.assertj.core.api.Assertions.assertThat;
910
import static org.junit.jupiter.api.Assumptions.assumeTrue;
1011
import static org.mockito.Mockito.lenient;
1112
import static org.mockito.Mockito.when;
1213

1314
import io.opentelemetry.instrumentation.api.instrumenter.SpanNameExtractor;
14-
import io.opentelemetry.instrumentation.api.internal.SemconvStability;
1515
import org.junit.jupiter.api.Test;
1616
import org.junit.jupiter.api.extension.ExtendWith;
1717
import org.mockito.Mock;
@@ -38,7 +38,7 @@ void normal() {
3838
@Test
3939
@SuppressWarnings("deprecation") // testing deprecated method
4040
void serviceNull() {
41-
assumeTrue(!SemconvStability.emitStableRpcSemconv());
41+
assumeTrue(!emitStableRpcSemconv());
4242

4343
RpcRequest request = new RpcRequest();
4444

@@ -50,7 +50,7 @@ void serviceNull() {
5050

5151
@Test
5252
void methodNull() {
53-
assumeTrue(!SemconvStability.emitStableRpcSemconv());
53+
assumeTrue(!emitStableRpcSemconv());
5454

5555
RpcRequest request = new RpcRequest();
5656

@@ -62,7 +62,7 @@ void methodNull() {
6262

6363
@Test
6464
void rpcMethodNull_fallsBackToSystemName() {
65-
assumeTrue(SemconvStability.emitStableRpcSemconv());
65+
assumeTrue(emitStableRpcSemconv());
6666

6767
RpcRequest request = new RpcRequest();
6868

@@ -74,7 +74,7 @@ void rpcMethodNull_fallsBackToSystemName() {
7474

7575
@Test
7676
void rpcMethodAndSystemNameNull() {
77-
assumeTrue(SemconvStability.emitStableRpcSemconv());
77+
assumeTrue(emitStableRpcSemconv());
7878

7979
RpcRequest request = new RpcRequest();
8080

0 commit comments

Comments
 (0)