Struct TracingProcessor 

pub struct TracingProcessor { /* private fields */ }

Tracing processor for OpenTelemetry integration

Implementations

impl TracingProcessor

pub fn new(service_name: impl Into<String>) -> Self

Create a new tracing processor with the given service name

pub fn from_global(service_name: &str) -> Self

Create a tracer from the global tracer provider

pub fn start_span(&self, message: &Message) -> Option<SpanGuard>

Start a span for a message

pub fn extract_context(params: &Option<Value>) -> Option<Context>

Extract trace context from request parameters Looks for a _trace_context field in params