Struct RetryMiddleware 

pub struct RetryMiddleware {
    pub max_retries: u32,
    pub retry_http_codes: Vec<u16>,
    pub backoff_factor: f64,
    pub max_delay: Duration,
}

Middleware that retries failed requests.

Fields

max_retries: u32

Maximum number of times to retry a request.

retry_http_codes: Vec<u16>

HTTP status codes that should trigger a retry.

backoff_factor: f64

Factor for exponential backoff (delay = backoff_factor * (2^retries)).

max_delay: Duration

Maximum delay between retries.

Implementations

impl RetryMiddleware

pub fn new() -> Self

Creates a new RetryMiddleware with default settings.

pub fn max_retries(self, max_retries: u32) -> Self

Sets the maximum number of times to retry a request.

pub fn retry_http_codes(self, retry_http_codes: Vec<u16>) -> Self

Sets the HTTP status codes that should trigger a retry.

pub fn backoff_factor(self, backoff_factor: f64) -> Self

Sets the factor for exponential backoff.

pub fn max_delay(self, max_delay: Duration) -> Self

Sets the maximum delay between retries.

Trait Implementations

impl Clone for RetryMiddleware

fn clone(&self) -> RetryMiddleware

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RetryMiddleware

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

Formats the value using the given formatter.

impl Default for RetryMiddleware

fn default() -> Self

Returns the “default value” for a type.

impl<C: Send + Sync> Middleware<C> for RetryMiddleware

fn name(&self) -> &str

fn process_request<'life0, 'life1, 'async_trait>( &'life0 mut self, _client: &'life1 C, request: Request, ) -> Pin<Box<dyn Future<Output = Result<MiddlewareAction<Request>, SpiderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn process_response<'life0, 'async_trait>( &'life0 mut self, response: Response, ) -> Pin<Box<dyn Future<Output = Result<MiddlewareAction<Response>, SpiderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn handle_error<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, request: &'life1 Request, error: &'life2 SpiderError, ) -> Pin<Box<dyn Future<Output = Result<MiddlewareAction<Request>, SpiderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,