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

Returns 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.

Cancellation is checked at three points: (1) Before each operation attempt. (2) During operation execution (via tokio::select!). (3) During retry delays.

This means cancellation may be delayed by up to one operation timeout if it occurs mid-execution.

Errors

Returns 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

Returns 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

Returns 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.