Move reactor context propagation operator instrumentation to separate instrumentation module (#5188)

This commit is contained in:
Lauri Tulmin 2022-01-20 21:00:48 +02:00 committed by GitHub
parent c5c0a2bcdf
commit dadf1e4d71
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 36 additions and 3 deletions

View File

@ -5,7 +5,7 @@
package io.opentelemetry.javaagent.instrumentation.reactor;
import static java.util.Arrays.asList;
import static java.util.Collections.singletonList;
import com.google.auto.service.AutoService;
import io.opentelemetry.javaagent.extension.instrumentation.InstrumentationModule;
@ -21,6 +21,6 @@ public class ReactorInstrumentationModule extends InstrumentationModule {
@Override
public List<TypeInstrumentation> typeInstrumentations() {
return asList(new HooksInstrumentation(), new ContextPropagationOperatorInstrumentation());
return singletonList(new HooksInstrumentation());
}
}

View File

@ -3,7 +3,7 @@
* SPDX-License-Identifier: Apache-2.0
*/
package io.opentelemetry.javaagent.instrumentation.reactor;
package io.opentelemetry.javaagent.instrumentation.reactor.operator;
import static net.bytebuddy.matcher.ElementMatchers.isMethod;
import static net.bytebuddy.matcher.ElementMatchers.isPublic;

View File

@ -0,0 +1,33 @@
/*
* Copyright The OpenTelemetry Authors
* SPDX-License-Identifier: Apache-2.0
*/
package io.opentelemetry.javaagent.instrumentation.reactor.operator;
import static io.opentelemetry.javaagent.extension.matcher.AgentElementMatchers.hasClassesNamed;
import static java.util.Collections.singletonList;
import com.google.auto.service.AutoService;
import io.opentelemetry.javaagent.extension.instrumentation.InstrumentationModule;
import io.opentelemetry.javaagent.extension.instrumentation.TypeInstrumentation;
import java.util.List;
import net.bytebuddy.matcher.ElementMatcher;
@AutoService(InstrumentationModule.class)
public class ContextPropagationOperatorInstrumentationModule extends InstrumentationModule {
public ContextPropagationOperatorInstrumentationModule() {
super("reactor", "reactor-3.1", "reactor-context-propagation-operator");
}
@Override
public ElementMatcher.Junction<ClassLoader> classLoaderMatcher() {
return hasClassesNamed("application.io.opentelemetry.context.Context");
}
@Override
public List<TypeInstrumentation> typeInstrumentations() {
return singletonList(new ContextPropagationOperatorInstrumentation());
}
}