Struct SseRetryConfig 

pub struct SseRetryConfig {
    pub max_retries: u32,
    pub max_backoff_ms: u32,
    pub min_sleep_ms: u32,
    pub backoff_multiplier: f32,
    pub jitter: bool,
}

Configuration for exponential backoff and jitter during stream reconnections.

Fields

max_retries: u32

The maximum number of consecutive connection attempts before giving up.

max_backoff_ms: u32

The absolute maximum wait time between connection attempts in milliseconds.

min_sleep_ms: u32

The absolute minimum wait time between connection attempts in milliseconds.

backoff_multiplier: f32

The multiplier applied to the delay after each failed attempt.

jitter: bool

Whether to apply randomness (jitter) to the reconnect delay.

Implementations

impl SseRetryConfig

pub const fn new() -> Self

Creates a new retry configuration with sensible defaults.

The default configuration applies an exponential backoff multiplier of 2.0, caps the maximum delay at 60,000 milliseconds (1 minute), caps the number of retries to 20, and enables jitter to prevent thundering herd scenarios.

Example

use sse_core::SseRetryConfig;

let config = SseRetryConfig::new();
assert_eq!(config.max_backoff_ms, 60_000);
assert!(config.jitter);

pub const fn disabled() -> Self

Creates a retry configuration that disables all automatic retries.

pub fn calculate_backoff_with_factor( &self, reconnect_time_ms: u32, attempt: u32, jitter_factor: f32, ) -> Option<Duration>

Calculates the delay duration for the next reconnection attempt.

Returns None if the attempt count exceeds Self::max_retries.

pub fn calculate_backoff( &self, reconnect_time_ms: u32, attempt: u32, ) -> Option<Duration>

Calculates the delay duration for the next reconnection attempt.

Returns None if the attempt count exceeds Self::max_retries.

Trait Implementations

impl Clone for SseRetryConfig

fn clone(&self) -> SseRetryConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SseRetryConfig

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

Formats the value using the given formatter.

impl Default for SseRetryConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for SseRetryConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for SseRetryConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Copy for SseRetryConfig