Struct TaskHookRegistry 

pub struct TaskHookRegistry { /* private fields */ }

Available on crate feature tasks only.

Registry for task hooks

Allows multiple hooks to be registered and called in sequence.

Implementations

impl TaskHookRegistry

pub fn new() -> TaskHookRegistry

Create an empty registry

pub fn with_logging() -> TaskHookRegistry

Create a registry with default logging hooks

pub fn register(&mut self, hook: Arc<dyn TaskHooks>)

Register a hook

pub async fn before_execute(&self, ctx: &TaskHookContext)

Call before_execute on all registered hooks

pub async fn after_execute(&self, ctx: &TaskHookContext, result: &str)

Call after_execute on all registered hooks

pub async fn on_failure( &self, ctx: &TaskHookContext, error: &str, ) -> RetryDecision

Call on_failure on all hooks, returning the first non-default decision

pub async fn on_timeout(&self, ctx: &TaskHookContext) -> RetryDecision

Call on_timeout on all hooks

pub async fn on_cancelled(&self, ctx: &TaskHookContext)

Call on_cancelled on all hooks

pub async fn should_retry(&self, ctx: &TaskHookContext, error: &str) -> bool

Check if any hook wants to prevent retry

pub fn is_empty(&self) -> bool

Check if any hooks are registered

pub fn len(&self) -> usize

Get the number of registered hooks

Trait Implementations

impl Clone for TaskHookRegistry

fn clone(&self) -> TaskHookRegistry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for TaskHookRegistry

fn default() -> TaskHookRegistry

Returns the “default value” for a type.