Struct RetryConfig 

pub struct RetryConfig { /* private fields */ }

Canonical retry configuration for messaging middleware.

Messaging retries historically retried every handler failure by default. RetryPolicy defaults to retrying only errors marked retryable, so this wrapper encodes the messaging-specific always-retry default explicitly.

Implementations

impl RetryConfig

pub fn new() -> Self

Create a retry config with messaging defaults.

pub const fn from_policy(policy: RetryPolicy) -> Self

Wrap an explicit resilience retry policy.

pub fn with_max_attempts(self, n: usize) -> Self

Set the maximum number of attempts (including the first call).

pub fn with_initial_backoff(self, d: Duration) -> Self

Set the initial backoff delay before the first retry.

pub fn with_max_backoff(self, d: Duration) -> Self

Set the upper bound on any single backoff delay.

pub fn with_backoff_factor(self, factor: f64) -> Self

Set the exponential backoff multiplication factor.

pub fn with_constant_backoff(self, backoff: ConstantBackoff) -> Self

Use a fixed delay for every retry attempt.

pub fn with_linear_backoff(self, backoff: LinearBackoff) -> Self

Use a linearly increasing retry delay.

pub fn with_jitter(self, enabled: bool) -> Self

Enable or disable retry jitter.

pub fn with_retry_if( self, f: impl Fn(&AppError) -> bool + Send + Sync + 'static, ) -> Self

Override the predicate used to decide whether an error is retried.

pub fn with_on_retry( self, f: impl Fn(u32, &AppError) + Send + Sync + 'static, ) -> Self

Register a callback called after each failed attempt before the next backoff sleep.

pub const fn policy(&self) -> &RetryPolicy

Borrow the underlying resilience policy.

pub fn into_policy(self) -> RetryPolicy

Convert into the underlying resilience policy.

Trait Implementations

impl Clone for RetryConfig

fn clone(&self) -> RetryConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RetryConfig

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

Formats the value using the given formatter.

impl Default for RetryConfig

fn default() -> Self

Returns the “default value” for a type.

impl From<RetryPolicy> for RetryConfig

fn from(policy: RetryPolicy) -> Self

Converts to this type from the input type.