Struct RetryExecutor 

pub struct RetryExecutor { /* private fields */ }

Executes an async operation with automatic retry.

Implementations

impl RetryExecutor

pub fn new(config: RetryConfig) -> Self

Creates a new retry executor with the given config.

pub fn with_defaults() -> Self

Creates a retry executor with default config.

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

where F: Fn() -> Fut, Fut: Future<Output = AptosResult<T>>,

Executes an async operation with retry logic.

The operation will be retried if it returns a retryable error, up to the configured maximum number of retries.

Errors

Returns an error if the operation fails and either the maximum number of retries has been exhausted or the error is not retryable according to the retry configuration.

pub async fn execute_with_predicate<F, Fut, T, P>( &self, operation: F, should_retry: P, ) -> AptosResult<T>

where F: Fn() -> Fut, Fut: Future<Output = AptosResult<T>>, P: Fn(&AptosError) -> bool,

Executes an async operation with retry logic and a custom retry predicate.

Errors

Returns an error if the operation fails and either the maximum number of retries has been exhausted or the custom retry predicate returns false.

Trait Implementations

impl Clone for RetryExecutor

fn clone(&self) -> RetryExecutor

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.