Struct RetryPolicy 

pub struct RetryPolicy {
    pub max_attempts: u32,
    pub backoff: BackoffStrategy,
    pub jitter: bool,
    retryable: Option<Arc<dyn Fn(&str) -> bool + Send + Sync>>,
}

Retry policy configuration.

Fields

max_attempts: u32

Maximum number of retry attempts.

backoff: BackoffStrategy

Backoff strategy.

jitter: bool

Whether to add jitter to delays.

retryable: Option<Arc<dyn Fn(&str) -> bool + Send + Sync>>

Implementations

impl RetryPolicy

pub fn new(max_attempts: u32) -> RetryPolicy

Create a new retry policy.

pub fn with_backoff(self, backoff: BackoffStrategy) -> RetryPolicy

Set backoff strategy.

pub fn without_jitter(self) -> RetryPolicy

Disable jitter.

pub fn with_retryable<F>(self, predicate: F) -> RetryPolicy

where F: Fn(&str) -> bool + Send + Sync + 'static,

Set retryable error predicate.

pub fn is_retryable(&self, error: &str) -> bool

Check if an error is retryable.

pub fn get_delay(&self, attempt: u32) -> Duration

Get delay for an attempt with optional jitter.

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

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

Execute an operation with retry.

Trait Implementations

impl Clone for RetryPolicy

fn clone(&self) -> RetryPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RetryPolicy

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

Formats the value using the given formatter.

impl Default for RetryPolicy

fn default() -> RetryPolicy

Returns the “default value” for a type.