Struct RetryPolicy

pub struct RetryPolicy {
    pub max_attempts: usize,
    pub initial_backoff: Duration,
    pub max_backoff: Duration,
    pub strategy: BackoffStrategy,
    pub jitter: Option<Duration>,
    pub retry_error: RetryError,
}

Policy controlling retry behavior for nodes.

Fields

max_attempts: usize

Maximum number of attempts (including the first).

initial_backoff: Duration

Initial backoff duration between retries.

max_backoff: Duration

Maximum backoff duration allowed.

strategy: BackoffStrategy

Strategy to compute backoff durations.

jitter: Option<Duration>

Optional fixed jitter to add to each backoff.

retry_error: RetryError

Error predicate controlling which errors to retry.

Implementations

impl RetryPolicy

pub fn new( max_attempts: usize, initial_backoff: Duration, max_backoff: Duration, strategy: BackoffStrategy, retry_error: RetryError, ) -> Self

Construct a new RetryPolicy.

pub fn with_jitter(self, jitter: Duration) -> Self

Specify a fixed jitter offset to add to each backoff.

pub fn should_retry(&self, error: &FloxideError, attempt: usize) -> bool

Determine whether an error should be retried for the given attempt (1-based).

pub fn backoff_duration(&self, attempt: usize) -> Duration

Compute the backoff duration before the next retry given the attempt count (1-based).

Trait Implementations

impl Clone for RetryPolicy

fn clone(&self) -> RetryPolicy

Returns a copy 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

Formats the value using the given formatter.