Struct WorkerRetryPolicy 

pub struct WorkerRetryPolicy {
    pub max_retries: usize,
    pub initial_backoff: Duration,
    pub max_backoff: Duration,
}

Bounded retry policy for worker poll acquisition and worker heartbeats.

Expected empty long polls and explicit Server capacity backpressure are normal worker states. Capacity backpressure honors the advertised retry delay without consuming this retry budget. Other transport failures, retryable HTTP 408/429 responses, and server errors are retried with capped exponential backoff. Authentication, protocol, codec, and handler failures are never retried by the worker. Explicit storage admission pauses also preserve the already-serialized worker request without consuming this budget or rerunning its handler. The delay is capped by max_backoff, and shutdown interrupts storage waits.

Fields

max_retries: usize

Number of retries after the initial request fails.

initial_backoff: Duration

Delay before the first retry.

max_backoff: Duration

Maximum delay between retries.

Trait Implementations

impl Clone for WorkerRetryPolicy

fn clone(&self) -> WorkerRetryPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for WorkerRetryPolicy

impl Debug for WorkerRetryPolicy

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

Formats the value using the given formatter.

impl Default for WorkerRetryPolicy

fn default() -> Self

Returns the “default value” for a type.