Struct RetryExecutor 

pub struct RetryExecutor { /* private fields */ }

Executes operations with retry logic using exponential backoff.

Implementations

impl RetryExecutor

pub fn new(policy: RetryPolicy) -> Self

Creates a new executor for policy.

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 (see is_retryable). Delays between retries follow exponential backoff with optional jitter.

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

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

Like execute, but each failure may carry a server-suggested delay (an HTTP 429 Retry-After). A hint replaces the backoff for that retry, capped at the policy’s max_delay so a hostile or misconfigured header cannot pin the caller.

Trait Implementations

impl Clone for RetryExecutor

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RetryExecutor

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

Formats the value using the given formatter.