Struct RetryPolicy 

pub struct RetryPolicy {
    pub max_retries: u32,
    pub backoff_initial: Duration,
    pub backoff_max: Duration,
    pub backoff_jitter: f64,
    pub http_statuses: StatusSet,
    pub respect_retry_after: bool,
    pub max_retry_after: Duration,
    pub retry_connection_errors: bool,
    pub retry_timeouts: bool,
    pub connect_only_before_send: bool,
}

Retry policy matching the official TypeSafe SDKs.

Default: 2 retries, 500 ms initial backoff, 5 s cap, 25% jitter, HTTP 408/429/5xx, connection errors, timeouts, and retry-after-ms / Retry-After up to 60 s.

Struct-update from RetryPolicy::default so private fields stay initialized: RetryPolicy { max_retries: 0, ..RetryPolicy::default() }.

Examples

use typesafe_rs::RetryPolicy;

let none = RetryPolicy::none();
assert_eq!(none.max_retries, 0);

let conservative = RetryPolicy::conservative();
assert!(!conservative.retry_timeouts);

Fields

max_retries: u32

Maximum retries after the initial attempt. Default: 2.

backoff_initial: Duration

First backoff delay. Default: 500 ms.

backoff_max: Duration

Backoff cap. Default: 5 s.

backoff_jitter: f64

Fraction of each backoff randomly subtracted, in [0, 1]. Default: 0.25.

http_statuses: StatusSet

HTTP statuses that are retried. Default: 408, 429, 500–599.

respect_retry_after: bool

Honor retry-after-ms / Retry-After up to Self::max_retry_after.

max_retry_after: Duration

Maximum server-requested delay that will be honored. Default: 60 s.

retry_connection_errors: bool

Retry connection failures. Default: true.

retry_timeouts: bool

Retry timeouts. Default: true.

connect_only_before_send: bool

When true, only connection errors that happen before bytes are sent are retried.

Set by RetryPolicy::conservative. Keep the default (false) unless you want that behaviour; prefer ..RetryPolicy::default() in struct updates.

Implementations

impl RetryPolicy

pub fn none() -> Self

No retries (max_retries = 0).

pub fn conservative() -> Self

Retry 408/429 and pre-send connection errors only. No 5xx, no timeouts.

pub fn parse_retry_after(headers: &HeaderMap) -> Option<Duration>

Parse retry-after-ms (preferred) or Retry-After into a delay.

Invalid values are ignored (None).

pub fn parse_retry_after_at( headers: &HeaderMap, now: SystemTime, ) -> Option<Duration>

Self::parse_retry_after with an injected now for HTTP-date values.

pub fn delay_after_failure( &self, attempt: u32, headers: Option<&HeaderMap>, ) -> Duration

Delay before the next attempt after a zero-based failed attempt.

pub fn delay_after_failure_with<F>( &self, attempt: u32, headers: Option<&HeaderMap>, rng: F, ) -> Duration

where F: FnOnce() -> f64,

Self::delay_after_failure with an injected RNG in [0, 1).

Tests should call this instead of reimplementing backoff math.

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.

impl PartialEq for RetryPolicy

fn eq(&self, other: &RetryPolicy) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for RetryPolicy