Struct RetryManager 

pub struct RetryManager<E> { /* private fields */ }

Generic retry manager for network operations.

Stateless and thread-safe - each operation maintains its own backoff state.

Implementations

impl<E> RetryManager<E>

where E: Error,

pub const fn new(config: RetryConfig) -> Result<Self>

Creates a new retry manager with the given configuration.

Errors

This function will return an error if the configuration is invalid.

pub async fn execute_with_retry_inner<F, Fut, T>( &self, operation_name: &str, operation: F, should_retry: impl Fn(&E) -> bool, create_error: impl Fn(String) -> E, cancel: Option<&CancellationToken>, ) -> Result<T, E>

where F: FnMut() -> Fut, Fut: Future<Output = Result<T, E>>,

Executes an operation with retry logic and optional cancellation.

Errors

This function will return an error if the operation fails after exhausting all retries, if the operation times out, if creating the backoff state fails, or if canceled.

pub async fn execute_with_retry<F, Fut, T>( &self, operation_name: &str, operation: F, should_retry: impl Fn(&E) -> bool, create_error: impl Fn(String) -> E, ) -> Result<T, E>

where F: FnMut() -> Fut, Fut: Future<Output = Result<T, E>>,

Executes an operation with retry logic.

Errors

This function will return an error if the operation fails after exhausting all retries, if the operation times out, or if creating the backoff state fails.

pub async fn execute_with_retry_with_cancel<F, Fut, T>( &self, operation_name: &str, operation: F, should_retry: impl Fn(&E) -> bool, create_error: impl Fn(String) -> E, cancellation_token: &CancellationToken, ) -> Result<T, E>

where F: FnMut() -> Fut, Fut: Future<Output = Result<T, E>>,

Executes an operation with retry logic and cancellation support.

Errors

This function will return an error if the operation fails after exhausting all retries, if the operation times out, if creating the backoff state fails, or if canceled.

Trait Implementations

impl<E: Clone> Clone for RetryManager<E>

fn clone(&self) -> RetryManager<E>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<E: Debug> Debug for RetryManager<E>

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

Formats the value using the given formatter.