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) -> Self

Creates a new retry manager with the given configuration.

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.

Cancellation mid-execution takes effect immediately by dropping the in-flight operation future. For non-idempotent operations (e.g. an order already on the wire) the outcome of the abandoned attempt is unknown to the caller.

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.