pub struct TracingMiddleware;Expand description
Middleware that emits tracing spans for task execution.
Trait Implementations§
Source§impl Debug for TracingMiddleware
impl Debug for TracingMiddleware
Source§impl Default for TracingMiddleware
impl Default for TracingMiddleware
Source§fn default() -> TracingMiddleware
fn default() -> TracingMiddleware
Returns the “default value” for a type. Read more
Source§impl Middleware for TracingMiddleware
impl Middleware for TracingMiddleware
Source§fn before<'life0, 'life1, 'async_trait>(
&'life0 self,
message: &'life1 TaskMessage,
) -> Pin<Box<dyn Future<Output = Result<(), KojinError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn before<'life0, 'life1, 'async_trait>(
&'life0 self,
message: &'life1 TaskMessage,
) -> Pin<Box<dyn Future<Output = Result<(), KojinError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Called before task execution. Return
Err to abort.Source§fn after<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
message: &'life1 TaskMessage,
_result: &'life2 Value,
) -> Pin<Box<dyn Future<Output = Result<(), KojinError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn after<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
message: &'life1 TaskMessage,
_result: &'life2 Value,
) -> Pin<Box<dyn Future<Output = Result<(), KojinError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Called after successful task execution.
Source§fn on_error<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
message: &'life1 TaskMessage,
error: &'life2 KojinError,
) -> Pin<Box<dyn Future<Output = Result<(), KojinError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn on_error<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
message: &'life1 TaskMessage,
error: &'life2 KojinError,
) -> Pin<Box<dyn Future<Output = Result<(), KojinError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Called when task execution fails.
Auto Trait Implementations§
impl Freeze for TracingMiddleware
impl RefUnwindSafe for TracingMiddleware
impl Send for TracingMiddleware
impl Sync for TracingMiddleware
impl Unpin for TracingMiddleware
impl UnsafeUnpin for TracingMiddleware
impl UnwindSafe for TracingMiddleware
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more