Struct RetryExecutor 

pub struct RetryExecutor<C: RetryClassifier> { /* private fields */ }

Executes operations with retry logic using exponential backoff.

Implementations

impl RetryExecutor<NetworkRetryClassifier>

pub fn new(policy: RetryPolicy) -> Self

Creates a new executor with the default network retry classifier.

impl<C: RetryClassifier> RetryExecutor<C>

pub fn with_classifier(policy: RetryPolicy, classifier: C) -> Self

Creates a new executor with a custom classifier.

pub async fn execute<F, Fut, T>(&self, operation: F) -> Result<T>

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

Executes an async operation with retry logic.

The operation will be retried up to max_attempts times if it fails with a retryable error. Delays between retries follow exponential backoff with optional jitter.

pub async fn execute_once<F, Fut, T>(&self, operation: F) -> Result<T>

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

Executes an async operation once without retries. Useful for operations that should not be retried.

Trait Implementations

impl<C: Clone + RetryClassifier> Clone for RetryExecutor<C>

fn clone(&self) -> RetryExecutor<C>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C: Debug + RetryClassifier> Debug for RetryExecutor<C>

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

Formats the value using the given formatter.