Struct RetryPolicy 

pub struct RetryPolicy { /* private fields */ }

Retry policy with maximum retry limits

Implementations

impl RetryPolicy

pub fn new(strategy: RetryStrategy, max_retries: u32) -> Self

Create a new retry policy

pub fn with_retry_on_timeout(self, retry: bool) -> Self

Set whether to retry on timeout errors

pub fn with_retry_on_rate_limit(self, retry: bool) -> Self

Set whether to retry on rate limit errors

pub fn should_retry(&self, message: &Message) -> bool

Check if a message should be retried

pub fn next_retry_eta(&self, message: &Message) -> Option<DateTime<Utc>>

Calculate the next ETA for a retry

pub fn create_retry_message(&self, message: &Message) -> Option<Message>

Create a retry message with updated retry count and ETA

pub fn strategy(&self) -> &RetryStrategy

Get the retry strategy

pub fn max_retries(&self) -> u32

Get the maximum number of retries

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.