Skip to content

Commit a6932b6

Browse files
authored
[OpenTelemetry] Add traceparent and tracestate to extended element metadata proto (#36963)
1 parent 4266ce0 commit a6932b6

File tree

1 file changed

+9
-0
lines changed
  • model/fn-execution/src/main/proto/org/apache/beam/model/fn_execution/v1

1 file changed

+9
-0
lines changed

model/fn-execution/src/main/proto/org/apache/beam/model/fn_execution/v1/beam_fn_api.proto

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -761,6 +761,15 @@ message Elements {
761761
// extensible and backward compatible
762762
message ElementMetadata {
763763
optional DrainMode.Enum drain = 1;
764+
// (Optional) As part of https://www.w3.org/TR/trace-context/ we are forwarding a trace and participating in it.
765+
// Traceparent header represents the incoming request in a tracing system in a common format.
766+
// Example value: 00-0af7651916cd43dd8448eb211c80319c-b7ad6b7169203331-01
767+
optional string traceparent = 2;
768+
// (Optional) tracestate extends traceparent with open telemetry data represented by a set of name/value pairs.
769+
// Format specified https://www.w3.org/TR/trace-context/#list for interoperability and commonly used
770+
// across IOs - Kafka, PubSub, http.
771+
// Example value: congo=t61rcWkgMzE
772+
optional string tracestate = 3;
764773
}
765774

766775
// Represent the encoded user timer for a given instruction, transform and

0 commit comments

Comments
 (0)