Struct TracingMiddleware 

pub struct TracingMiddleware { /* private fields */ }

Middleware that adds distributed tracing to message processing.

This middleware creates trace spans for each message, capturing:

• Message ID and metadata
• Processing duration
• Success/failure status
• Error details (if any)

When the tracing feature is enabled, it uses the tracing crate to emit structured events. Otherwise, it logs to stdout.

Example

use foxtive_worker::TracingMiddleware;

let middleware = TracingMiddleware::new("my-service");

Implementations

impl TracingMiddleware

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

Create a new tracing middleware.

Arguments

• service_name - Name of the service for trace identification

Trait Implementations

impl Debug for TracingMiddleware

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Middleware for TracingMiddleware

fn name(&self) -> &str

Get the name of this middleware for debugging and logging.

fn handle<'life0, 'async_trait>( &'life0 self, message: ReceivedMessage<Value>, next: Box<dyn MessageHandler>, ) -> Pin<Box<dyn Future<Output = Result<MiddlewareResult, WorkerError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Process a message with access to the next handler in the chain.