feat(propagators): ot-tracer and xray (#838)

This commit is contained in:
Frank Spitulski 2020-07-30 00:18:04 -07:00 committed by GitHub
parent adab0efcd6
commit 4cec42b04a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 12 additions and 9 deletions

View File

@ -20,8 +20,10 @@ import com.google.common.collect.ImmutableMap;
import io.opentelemetry.OpenTelemetry;
import io.opentelemetry.context.propagation.DefaultContextPropagators;
import io.opentelemetry.context.propagation.HttpTextFormat;
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.trace.propagation.HttpTraceContext;
import java.util.List;
import java.util.Map;
@ -36,17 +38,18 @@ public class PropagatorsInitializer {
private static final String B3 = "b3";
private static final String B3_SINGLE = "b3single";
private static final String JAEGER = "jaeger";
private static final String OT_TRACER = "ottracer";
private static final String XRAY = "xray";
private static final Map<String, HttpTextFormat> TEXTMAP_PROPAGATORS =
ImmutableMap.of(
TRACE_CONTEXT,
new HttpTraceContext(),
B3,
B3Propagator.getMultipleHeaderPropagator(),
B3_SINGLE,
B3Propagator.getSingleHeaderPropagator(),
JAEGER,
new JaegerPropagator());
ImmutableMap.<String, HttpTextFormat>builder()
.put(TRACE_CONTEXT, new HttpTraceContext())
.put(B3, B3Propagator.getMultipleHeaderPropagator())
.put(B3_SINGLE, B3Propagator.getSingleHeaderPropagator())
.put(JAEGER, new JaegerPropagator())
.put(OT_TRACER, OtTracerPropagator.getInstance())
.put(XRAY, new AwsXRayPropagator())
.build();
/** Initialize OpenTelemetry global Propagators with propagator list, if any. */
public static void initializePropagators(List<String> propagators) {