open-telemetry
/
opentelemetry-java-instrumentation
mirror of https://github.com/open-telemetry/opentelemetry-java-instrumentation.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add support for TraceMultiPropagator (#849)

This commit is contained in:
Sergei Malafeev 2020-08-01 01:18:55 +08:00 committed by GitHub
parent adec806300
commit 8c44dd00e1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 15 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
agent-tooling/src/main/java/io/opentelemetry/auto/tooling/PropagatorsInitializer.java
View File

@ -24,7 +24,10 @@ import io.opentelemetry.extensions.trace.propagation.AwsXRayPropagator;
import io.opentelemetry.extensions.trace.propagation.B3Propagator;
import io.opentelemetry.extensions.trace.propagation.JaegerPropagator;
import io.opentelemetry.extensions.trace.propagation.OtTracerPropagator;
import io.opentelemetry.extensions.trace.propagation.TraceMultiPropagator;
import io.opentelemetry.extensions.trace.propagation.TraceMultiPropagator.Builder;
import io.opentelemetry.trace.propagation.HttpTraceContext;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import org.slf4j.Logger;
@ -60,23 +63,26 @@ public class PropagatorsInitializer {
DefaultContextPropagators.Builder propagatorsBuilder = DefaultContextPropagators.builder();
boolean addedPropagator = false;
List<HttpTextFormat> textPropagators = new ArrayList<>(propagators.size());
for (String propagatorId : propagators) {
HttpTextFormat textPropagator = TEXTMAP_PROPAGATORS.get(propagatorId.trim().toLowerCase());
if (textPropagator != null) {
if (addedPropagator) {
log.warn(
"Only one propagator per concern can be added, " + textPropagator + " is ignored");
continue;
}
propagatorsBuilder.addHttpTextFormat(textPropagator);
textPropagators.add(textPropagator);
log.info("Added " + textPropagator + " propagator");
addedPropagator = true;
} else {
log.warn("No matching propagator for " + propagatorId);
}
}
if (textPropagators.size() > 1) {
Builder traceMultiPropagatorBuilder = TraceMultiPropagator.builder();
for (HttpTextFormat textPropagator : textPropagators) {
traceMultiPropagatorBuilder.addPropagator(textPropagator);
}
propagatorsBuilder.addHttpTextFormat(traceMultiPropagatorBuilder.build());
} else if (textPropagators.size() == 1) {
propagatorsBuilder.addHttpTextFormat(textPropagators.get(0));
}
// Register it in the global propagators:
OpenTelemetry.setPropagators(propagatorsBuilder.build());
}
}