Struct StreamRetryPolicy 

pub struct StreamRetryPolicy {
    pub max_attempts: u32,
    pub initial_delay: Duration,
    pub backoff_multiplier: f64,
    pub max_delay: Duration,
    pub jitter: bool,
}

Configures when and how many times an operation should be retried

Fields

max_attempts: u32

Maximum number of retry attempts (0 = no retries)

initial_delay: Duration

Initial delay before first retry

backoff_multiplier: f64

Multiplier applied to delay after each retry (exponential backoff)

max_delay: Duration

Maximum delay cap (prevents unbounded backoff)

jitter: bool

Whether to add random jitter (fraction of delay) to prevent thundering herd

Implementations

impl StreamRetryPolicy

pub fn delay_for_attempt(&self, attempt: u32) -> Duration

Returns the delay before the nth retry attempt (0-indexed).

Incorporates exponential backoff and an optional pseudo-random jitter derived deterministically from the attempt number (no rand crate needed).

pub fn retry<F, T, E>(&self, operation_name: &str, f: F) -> FaultResult<T>

where F: FnMut() -> Result<T, E>, E: Debug,

Executes a fallible synchronous closure with retries.

Uses std::thread::sleep for backoff delays. For async contexts see StreamRetryPolicy::retry_async.

pub async fn retry_async<F, Fut, T, E>( &self, operation_name: &str, f: F, ) -> FaultResult<T>

where F: FnMut() -> Fut, Fut: Future<Output = Result<T, E>>, E: Debug,

Executes a fallible async closure with retries and tokio async sleep.

Trait Implementations

impl Clone for StreamRetryPolicy

fn clone(&self) -> StreamRetryPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamRetryPolicy

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

Formats the value using the given formatter.

impl Default for StreamRetryPolicy

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for StreamRetryPolicy

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for StreamRetryPolicy

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.