Struct RetryPolicy 

pub struct RetryPolicy {
    pub max_retries: usize,
    pub initial_backoff: Duration,
    pub max_backoff: Duration,
    pub backoff_multiplier: f64,
    pub retryable_statuses: Vec<u16>,
}

Retry policy for failed requests.

Controls exponential backoff behavior for retryable HTTP status codes and network errors. The backoff duration is calculated as: initial_backoff * backoff_multiplier^attempt, capped at max_backoff.

Examples

use crawlkit_engine::http::RetryPolicy;
use std::time::Duration;

let policy = RetryPolicy::default();
assert_eq!(policy.max_retries, 3);
assert!(policy.is_retryable(429));
assert!(!policy.is_retryable(200));

Fields

max_retries: usize

Maximum number of retry attempts.

initial_backoff: Duration

Initial backoff duration.

max_backoff: Duration

Maximum backoff duration.

backoff_multiplier: f64

Multiplier applied to backoff on each attempt.

retryable_statuses: Vec<u16>

HTTP status codes that trigger a retry.

Implementations

impl RetryPolicy

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

Returns the backoff duration for a given attempt number (0-indexed).

The duration grows exponentially: initial_backoff * multiplier^attempt, capped at max_backoff.

Examples

use crawlkit_engine::http::RetryPolicy;
use std::time::Duration;

let policy = RetryPolicy::default();
assert_eq!(policy.backoff_duration(0), Duration::from_secs(1));
assert_eq!(policy.backoff_duration(1), Duration::from_secs(2));
assert_eq!(policy.backoff_duration(10), Duration::from_secs(30)); // capped

pub fn is_retryable(&self, status: u16) -> bool

Returns true if the given status code should trigger a retry.

By default retries on: 429 (Too Many Requests), 500, 502, 503, 504.

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<'de> Deserialize<'de> for RetryPolicy

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for RetryPolicy

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.