Struct RetryPolicy 

pub struct RetryPolicy {
    pub max_attempts: u32,
    pub backoff: BackoffKind,
    pub base: Duration,
    pub max: Duration,
    pub jitter: bool,
    pub retry_on: RetryClassSet,
}

Retry configuration shared by the pipeline loop and source connectors.

Fields

max_attempts: u32

Total attempts including the first (1 = no retry).

backoff: BackoffKind

Backoff growth shape.

base: Duration

Base delay.

max: Duration

Per-sleep cap (pre-jitter).

jitter: bool

Whether to apply [0.5, 1.5) jitter.

retry_on: RetryClassSet

Which error classes are retried.

Implementations

impl RetryPolicy

pub fn is_retriable(&self, err: &FaucetError) -> bool

Whether err should be retried under this policy: it must classify into a class that is in retry_on.

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

Formats the value using the given formatter.

impl Default for RetryPolicy

fn default() -> Self

Returns the “default value” for a type.