Struct SharedRateLimiter 

pub struct SharedRateLimiter { /* private fields */ }

Thread-safe rate limiter for parallel API requests

Implementations

impl SharedRateLimiter

pub fn new(max_concurrent: usize) -> Self

Create a new shared rate limiter with given concurrency

pub async fn acquire(&self) -> RateLimitGuard

Acquire a permit and wait for rate limit, returns a guard

pub fn on_success(&self)

Handle a successful request - reset backoff

pub fn on_rate_limit(&self)

Handle a rate limit (429) response - increase backoff

pub fn should_pause(&self) -> bool

Check if we should pause sync due to repeated rate limits

pub fn current_backoff(&self) -> Duration

Get the current backoff duration

pub fn pause_duration(&self) -> Duration

Get pause duration (30 minutes after 5 consecutive 429s)

Trait Implementations

impl Clone for SharedRateLimiter

fn clone(&self) -> SharedRateLimiter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for SharedRateLimiter

fn default() -> Self

Returns the “default value” for a type.