pub struct LoggingHooks;Available on crate feature
tasks only.Expand description
Logging hooks that emit tracing events
Trait Implementations§
Source§impl TaskHooks for LoggingHooks
impl TaskHooks for LoggingHooks
Source§fn before_execute<'life0, 'life1, 'async_trait>(
&'life0 self,
ctx: &'life1 TaskHookContext,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
LoggingHooks: 'async_trait,
fn before_execute<'life0, 'life1, 'async_trait>(
&'life0 self,
ctx: &'life1 TaskHookContext,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
LoggingHooks: 'async_trait,
Called before a task starts execution Read more
Source§fn after_execute<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
ctx: &'life1 TaskHookContext,
result: &'life2 str,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
LoggingHooks: 'async_trait,
fn after_execute<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
ctx: &'life1 TaskHookContext,
result: &'life2 str,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
LoggingHooks: 'async_trait,
Called after a task completes successfully Read more
Source§fn on_failure<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
ctx: &'life1 TaskHookContext,
error: &'life2 str,
) -> Pin<Box<dyn Future<Output = RetryDecision> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
LoggingHooks: 'async_trait,
fn on_failure<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
ctx: &'life1 TaskHookContext,
error: &'life2 str,
) -> Pin<Box<dyn Future<Output = RetryDecision> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
LoggingHooks: 'async_trait,
Called when a task fails Read more
Source§fn on_timeout<'life0, 'life1, 'async_trait>(
&'life0 self,
ctx: &'life1 TaskHookContext,
) -> Pin<Box<dyn Future<Output = RetryDecision> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
LoggingHooks: 'async_trait,
fn on_timeout<'life0, 'life1, 'async_trait>(
&'life0 self,
ctx: &'life1 TaskHookContext,
) -> Pin<Box<dyn Future<Output = RetryDecision> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
LoggingHooks: 'async_trait,
Called when a task times out Read more
Source§fn on_cancelled<'life0, 'life1, 'async_trait>(
&'life0 self,
ctx: &'life1 TaskHookContext,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
LoggingHooks: 'async_trait,
fn on_cancelled<'life0, 'life1, 'async_trait>(
&'life0 self,
ctx: &'life1 TaskHookContext,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
LoggingHooks: 'async_trait,
Called when a task is cancelled Read more
Source§fn should_retry<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
_ctx: &'life1 TaskHookContext,
_error: &'life2 str,
) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Self: 'async_trait,
fn should_retry<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
_ctx: &'life1 TaskHookContext,
_error: &'life2 str,
) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Self: 'async_trait,
Called when a task is about to be retried Read more
Auto Trait Implementations§
impl Freeze for LoggingHooks
impl RefUnwindSafe for LoggingHooks
impl Send for LoggingHooks
impl Sync for LoggingHooks
impl Unpin for LoggingHooks
impl UnsafeUnpin for LoggingHooks
impl UnwindSafe for LoggingHooks
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> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
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 moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request