Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion dependencyManagement/build.gradle.kts
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ val DEPENDENCY_BOMS = listOf(

val autoServiceVersion = "1.1.1"
val autoValueVersion = "1.11.0"
val errorProneVersion = "2.32.0"
val errorProneVersion = "2.33.0"
val byteBuddyVersion = "1.15.3"
val asmVersion = "9.7"
val jmhVersion = "1.37"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ public CouchbaseInstrumentationModule() {

@Override
public boolean isHelperClass(String className) {
return className.equals("rx.__OpenTelemetryTracingUtil");
return className.equals("rx.OpenTelemetryTracingUtil");
}

@Override
Expand All @@ -39,6 +39,6 @@ public String getModuleGroup() {

@Override
public List<String> injectedClassNames() {
return singletonList("rx.__OpenTelemetryTracingUtil");
return singletonList("rx.OpenTelemetryTracingUtil");
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@
import io.opentelemetry.api.OpenTelemetry;
import io.opentelemetry.instrumentation.graphql.internal.OpenTelemetryInstrumentationHelper;

@SuppressWarnings("AbbreviationAsWordInName")
@SuppressWarnings({"AbbreviationAsWordInName", "MemberName"})
public final class GraphQLTelemetry {
private static final String INSTRUMENTATION_NAME = "io.opentelemetry.graphql-java-12.0";

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@
import io.opentelemetry.api.OpenTelemetry;

/** A builder of {@link GraphQLTelemetry}. */
@SuppressWarnings("AbbreviationAsWordInName")
@SuppressWarnings({"AbbreviationAsWordInName", "MemberName"})
public final class GraphQLTelemetryBuilder {

private final OpenTelemetry openTelemetry;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@
import io.opentelemetry.instrumentation.api.instrumenter.Instrumenter;
import io.opentelemetry.instrumentation.graphql.internal.OpenTelemetryInstrumentationHelper;

@SuppressWarnings("AbbreviationAsWordInName")
@SuppressWarnings({"AbbreviationAsWordInName", "MemberName"})
public final class GraphQLTelemetry {

/** Returns a new {@link GraphQLTelemetry} configured with the given {@link OpenTelemetry}. */
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@
import io.opentelemetry.api.OpenTelemetry;

/** A builder of {@link GraphQLTelemetry}. */
@SuppressWarnings("AbbreviationAsWordInName")
@SuppressWarnings({"AbbreviationAsWordInName", "MemberName"})
public final class GraphQLTelemetryBuilder {

private final OpenTelemetry openTelemetry;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ public HystrixInstrumentationModule() {

@Override
public boolean isHelperClass(String className) {
return className.equals("rx.__OpenTelemetryTracingUtil");
return className.equals("rx.OpenTelemetryTracingUtil");
}

@Override
Expand All @@ -33,6 +33,6 @@ public List<TypeInstrumentation> typeInstrumentations() {

@Override
public List<String> injectedClassNames() {
return singletonList("rx.__OpenTelemetryTracingUtil");
return singletonList("rx.OpenTelemetryTracingUtil");
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -97,6 +97,7 @@ void idsGeneratedWhenSpanProvided() throws InvocationTargetException, IllegalAcc
try {
getMdcCopy = logRecords.get(0).getClass().getMethod("getMdcCopy");
} catch (NoSuchMethodException ignored) {
// ignored
}

assertThat(logRecords.get(0).getMessage()).isEqualTo("log message 1");
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -82,6 +82,7 @@ public void cleanup() throws IOException, TimeoutException {
conn.close();
}
} catch (ShutdownSignalException ignored) {
// ignored
}
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,7 @@ static void cleanupAll() {
}

@BeforeEach
void setup() throws NoSuchMethodException, InvocationTargetException, IllegalAccessException {
void setup() throws InvocationTargetException, IllegalAccessException {
String newAddress = address;
if (useRedisProtocol()) {
// Newer versions of redisson require scheme, older versions forbid it
Expand All @@ -95,6 +95,7 @@ void setup() throws NoSuchMethodException, InvocationTargetException, IllegalAcc
.getMethod("setPingConnectionInterval", int.class)
.invoke(singleServerConfig, 0);
} catch (NoSuchMethodException ignored) {
// ignored
}
redisson = Redisson.create(config);
testing.clearData();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -99,6 +99,7 @@ void setup() throws InvocationTargetException, IllegalAccessException {
.getMethod("setPingConnectionInterval", int.class)
.invoke(singleServerConfig, 0);
} catch (NoSuchMethodException ignored) {
// ignored
}
redisson = Redisson.create(config);
testing.clearData();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,8 +9,8 @@
import io.opentelemetry.context.Scope;
import io.opentelemetry.instrumentation.api.instrumenter.Instrumenter;
import rx.Observable;
import rx.OpenTelemetryTracingUtil;
import rx.Subscriber;
import rx.__OpenTelemetryTracingUtil;

public final class TracedOnSubscribe<T, REQUEST> implements Observable.OnSubscribe<T> {
private final Observable.OnSubscribe<T> delegate;
Expand All @@ -20,7 +20,7 @@ public final class TracedOnSubscribe<T, REQUEST> implements Observable.OnSubscri

public TracedOnSubscribe(
Observable<T> originalObservable, Instrumenter<REQUEST, ?> instrumenter, REQUEST request) {
delegate = __OpenTelemetryTracingUtil.extractOnSubscribe(originalObservable);
delegate = OpenTelemetryTracingUtil.extractOnSubscribe(originalObservable);
this.instrumenter = instrumenter;
this.request = request;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,11 +8,10 @@
/**
* This class must be in the rx package in order to access the package accessible onSubscribe field.
*/
@SuppressWarnings("checkstyle:TypeName")
public final class __OpenTelemetryTracingUtil {
public final class OpenTelemetryTracingUtil {
public static <T> Observable.OnSubscribe<T> extractOnSubscribe(Observable<T> observable) {
return observable.onSubscribe;
}

private __OpenTelemetryTracingUtil() {}
private OpenTelemetryTracingUtil() {}
}
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ public class ShadowPackageRenamingTest {
"org.objectweb.asm",
"com.kenai",
// Custom RxJava Utility
"rx.__OpenTelemetryTracingUtil");
"rx.OpenTelemetryTracingUtil");

@Test
void agentDependenciesRenamed() throws Exception {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -448,6 +448,7 @@ void errorSpan() {
try {
doRequest(method, uri);
} catch (Throwable ignored) {
// ignored
}
});

Expand Down
Loading