Struct OperationRetryConfig 

pub struct OperationRetryConfig {
    pub initial_backoff: Duration,
    pub max_backoff: Duration,
    pub max_retries: Option<u32>,
}

Configuration for lookup, partition-metadata, producer-open, and subscribe retries.

Fields

initial_backoff: Duration

Initial delay before the first re-issue.

max_backoff: Duration

Maximum delay between re-issues.

max_retries: Option<u32>

Maximum re-issues after the initial attempt.

Some(0) disables retries. None removes the count cap, but runtime engines still stop at the enclosing operation deadline.

Implementations

impl OperationRetryConfig

pub fn should_retry_after_failure(&self, failures: u32) -> bool

Whether a broker failure numbered failures should schedule a re-issue.

failures is one-based: the first failed attempt passes 1.

pub fn delay_after_failure(&self, failures: u32) -> Duration

Delay for the one-based failed-attempt number.

Trait Implementations

impl Clone for OperationRetryConfig

fn clone(&self) -> OperationRetryConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OperationRetryConfig

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

Formats the value using the given formatter.

impl Default for OperationRetryConfig

fn default() -> OperationRetryConfig

Returns the “default value” for a type.

impl Eq for OperationRetryConfig

impl PartialEq for OperationRetryConfig

fn eq(&self, other: &OperationRetryConfig) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for OperationRetryConfig