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>>, ) -> Self

Wrap a processor with tracing.

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.