Struct AdvancedRecoveryExecutor 

pub struct AdvancedRecoveryExecutor { /* private fields */ }

Enhanced error recovery executor with advanced recovery strategies.

Implementations

impl AdvancedRecoveryExecutor

pub fn new(policy: RecoveryPolicy) -> Self

Create a new advanced recovery executor.

pub fn coordinator(&self) -> Arc<RecoveryCoordinator>

Get recovery coordinator.

pub fn bulk_handler(&self) -> Arc<BulkRecoveryHandler>

Get bulk recovery handler.

pub async fn retry_adaptive<F, Fut>( &self, error: Error, attempts: u32, initial_delay: Duration, max_delay: Duration, multiplier: f64, jitter: JitterStrategy, operation: F, ) -> Result<Value>

where F: Fn() -> Fut, Fut: Future<Output = Result<Value>>,

Execute with adaptive retry including jitter.

pub async fn execute_with_deadline<F, Fut>( &self, operation_id: &str, operation: F, deadline: &mut RecoveryDeadline, base_strategy: &RecoveryStrategy, ) -> Result<Value>

where F: Fn() -> Fut + Clone, Fut: Future<Output = Result<Value>>,

Execute with deadline-aware recovery.

pub fn register_handler( &mut self, name: String, handler: Arc<dyn RecoveryHandler>, )

Register a recovery handler.

Trait Implementations

impl Debug for AdvancedRecoveryExecutor

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

Formats the value using the given formatter.