Struct TracingProcessor 

pub struct TracingProcessor { /* private fields */ }

A processor wrapper that emits tracing spans for each step.

This processor wraps another processor and adds distributed tracing by:

1. Starting a native OpenTelemetry span for each exchange
2. Propagating the OTel context through exchange.otel_context
3. Recording errors and status on the span

When no OTel provider is configured (noop provider), spans are no-ops with minimal overhead.

Implementations

impl TracingProcessor

pub fn new( inner: BoxProcessor, route_id: String, step_index: usize, detail_level: DetailLevel, metrics: Option<Arc<dyn MetricsCollector>>, label: Option<Arc<str>>, to_uri: Option<Arc<str>>, kind_hint: SpanKindHint, ) -> Self

Wrap a processor with tracing.

label names the span after the DSL step it wraps (e.g. log, to:direct); when None the span falls back to the positional step-{index} id. kind_hint selects the OTel span kind for the step span and is converted once here. to_uri carries the declared endpoint URI for To steps (steplatency 2.1) and labels the call-time step_duration_secs histogram; None for non-To steps.

pub fn with_spans_enabled(self, enabled: bool) -> Self

Sets whether step spans are created (metrics still flow when off).

pub fn with_metric_levers(self, levers: MetricsLeversConfig) -> Self

Sets the per-family metric levers. The error family ignores them.

Trait Implementations

impl Clone for TracingProcessor

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Service<Exchange> for TracingProcessor

type Response = Exchange

Responses given by the service.

type Error = CamelError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<Exchange, CamelError>> + Send>>

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, exchange: Exchange) -> Self::Future

Process the request and return the response asynchronously.