Add B3 Single and Jaeger propagators (#658)

Signed-off-by: Sergei Malafeev <sergei@malafeev.org>
This commit is contained in:
Sergei Malafeev 2020-07-10 00:55:47 +08:00 committed by GitHub
parent f3ed2d320a
commit fcfee71e7b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 1 deletions

View File

@ -21,6 +21,7 @@ import io.opentelemetry.OpenTelemetry;
import io.opentelemetry.context.propagation.DefaultContextPropagators;
import io.opentelemetry.context.propagation.HttpTextFormat;
import io.opentelemetry.contrib.trace.propagation.B3Propagator;
import io.opentelemetry.contrib.trace.propagation.JaegerPropagator;
import io.opentelemetry.trace.propagation.HttpTraceContext;
import java.util.List;
import java.util.Map;
@ -30,10 +31,19 @@ import lombok.extern.slf4j.Slf4j;
public class PropagatorsInitializer {
private static final String TRACE_CONTEXT = "tracecontext";
private static final String B3 = "b3";
private static final String B3_SINGLE = "b3single";
private static final String JAEGER = "jaeger";
private static final Map<String, HttpTextFormat> TEXTMAP_PROPAGATORS =
ImmutableMap.of(
TRACE_CONTEXT, new HttpTraceContext(), B3, B3Propagator.getMultipleHeaderPropagator());
TRACE_CONTEXT,
new HttpTraceContext(),
B3,
B3Propagator.getMultipleHeaderPropagator(),
B3_SINGLE,
B3Propagator.getSingleHeaderPropagator(),
JAEGER,
new JaegerPropagator());
/** Initialize OpenTelemetry global Propagators with propagator list, if any. */
public static void initializePropagators(List<String> propagators) {