Struct RetryPolicy 

pub struct RetryPolicy {
    pub max_retries: u32,
    pub base_delay_ms: u64,
    pub max_delay_ms: u64,
    pub multiplier: f64,
}

Retry/backoff policy configuration.

LLM-centric guidance:

• Useful when downstream model APIs (OpenAI, Anthropic, Ollama, etc.) return transient failures like HTTP 429 (rate limit), 408 (timeout), or 5xx. Your worker can NACK the message to reschedule it with a computed delay based on this policy.
• Combine with an appropriate visibility timeout so only one worker attempts a long-running generation at a time.
• After max_retries, messages are dead-lettered to infraqueue:{topic}:dlq for manual inspection.

Fields:

• max_retries: reschedules allowed before dead-letter.
• base_delay_ms: initial delay on first failure.
• max_delay_ms: upper bound for any backoff delay.
• multiplier: exponential growth factor (e.g., 2.0 doubles each attempt).

Fields

max_retries: u32

base_delay_ms: u64

max_delay_ms: u64

multiplier: f64

Implementations

impl RetryPolicy

pub fn backoff_delay_ms(&self, retry_count: u32) -> u64

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.