Struct ReconnectRateLimiter 

pub struct ReconnectRateLimiter { /* private fields */ }

Rate limiter for reconnection attempts.

Implementations

impl ReconnectRateLimiter

pub fn new(delay_ms: u64) -> Self

Create a new rate limiter with the given base delay.

pub async fn get_turn(&self, url: &str) -> Duration

Get a “turn” to attempt a connection.

This may wait if too many rapid attempts have been made.

pub async fn on_conn(&self, url: &str)

Called when a connection is established.

pub async fn on_diss(&self, url: &str)

Called when a connection is disconnected.

pub async fn is_connected(&self, url: &str) -> bool

Check if a URL is currently connected.

pub async fn failure_count(&self, url: &str) -> u32

Get the current failure count for a URL.

pub async fn reset(&self, url: &str)

Reset the state for a URL.

Trait Implementations

impl Debug for ReconnectRateLimiter

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

Formats the value using the given formatter.