temp

Author: lucaspimentel

dd-trace-core/src/main/java/datadog/trace/core/baggage/W3CBaggageExtractor.java

@@ -0,0 +1,22 @@
+package datadog.trace.core.baggage;
+
+import datadog.trace.bootstrap.instrumentation.api.AgentPropagation;
+import datadog.trace.bootstrap.instrumentation.api.TagContext;
+import datadog.trace.core.propagation.HttpCodec;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class W3CBaggageExtractor implements HttpCodec.Extractor {
+  private static final Logger LOGGER = LoggerFactory.getLogger(W3CBaggageExtractor.class);
+  private final HttpCodec.Extractor delegate;
+
+  public W3CBaggageExtractor(HttpCodec.Extractor delegate) {
+    this.delegate = delegate;
+  }
+
+  @Override
+  public <C> TagContext extract(C carrier, AgentPropagation.ContextVisitor<C> getter) {
+    // delegate to the default HTTP extraction
+    return this.delegate.extract(carrier, getter);
+  }
+}

dd-trace-core/src/main/java/datadog/trace/core/baggage/W3CBaggageInjector.java

@@ -0,0 +1,21 @@
+package datadog.trace.core.baggage;
+
+import datadog.trace.bootstrap.instrumentation.api.AgentPropagation;
+import datadog.trace.bootstrap.instrumentation.api.AgentSpan;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.Map;
+
+public class W3CBaggageInjector {
+  private static final Logger LOGGER = LoggerFactory.getLogger(W3CBaggageInjector.class);
+
+  public <C> void inject(AgentSpan span, C carrier, AgentPropagation.Setter<C> setter) {
+    Iterable<Map.Entry<String, String>> baggageItems = span.context().baggageItems();
+    // get span.context().baggageItems() and build the baggage header value like "key1=value1,key2=value2"
+
+    String headerValue = "TODO";
+    setter.set(carrier, "baggage", headerValue);
+  }
+}
+