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
'life0: 'async_trait,
'life1: 'async_trait,
TracingMiddleware: 'async_trait,
fn before<'life0, 'life1, 'async_trait>(
&'life0 self,
message: &'life1 TaskMessage,
) -> Pin<Box<dyn Future<Output = Result<(), KojinError>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
TracingMiddleware: '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
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
TracingMiddleware: '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
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
TracingMiddleware: '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
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
TracingMiddleware: '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
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
TracingMiddleware: '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
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more