Struct RetryManager 

pub struct RetryManager { /* private fields */ }

Retry manager with circuit breaker

Implementations

impl RetryManager

pub fn new( strategy: RetryStrategy, circuit_breaker_config: CircuitBreakerConfig, ) -> Self

pub async fn execute_with_retry<F, T, E>( &mut self, operation_name: &str, operation: F, ) -> Result<T, RetryError>

where F: Fn() -> Pin<Box<dyn Future<Output = Result<T, E>> + Send>> + Send + Sync, E: Error + Send + Sync + 'static,

Execute an operation with retry logic

pub fn get_operation_stats( &self, operation_name: &str, ) -> Option<&OperationStats>

Get operation statistics

pub fn get_all_stats(&self) -> &HashMap<String, OperationStats>

Get all operation statistics

pub fn reset_circuit_breaker(&mut self)

Reset circuit breaker

pub fn update_strategy(&mut self, strategy: RetryStrategy)

Update retry strategy