Struct WorkerRateLimiter 

pub struct WorkerRateLimiter { /* private fields */ }

Thread-safe per-worker rate limiter

Wraps a rate limiter for safe concurrent access from multiple worker threads.

Implementations

impl WorkerRateLimiter

pub fn new() -> Self

Create a new worker rate limiter

pub fn with_default(config: RateLimitConfig) -> Self

Create with a default rate limit

pub fn set_task_rate( &self, task_name: impl Into<String>, config: RateLimitConfig, )

Set rate limit for a specific task type

pub fn remove_task_rate(&self, task_name: &str)

Remove rate limit for a specific task type

pub fn try_acquire(&self, task_name: &str) -> bool

Try to acquire a permit for a specific task

pub fn time_until_available(&self, task_name: &str) -> Duration

Get time until a task can be executed

pub fn has_rate_limit(&self, task_name: &str) -> bool

Check if a task type has a rate limit configured

pub fn reset_all(&self)

Reset all rate limiters

Trait Implementations

impl Clone for WorkerRateLimiter

fn clone(&self) -> WorkerRateLimiter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerRateLimiter

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

Formats the value using the given formatter.

impl Default for WorkerRateLimiter

fn default() -> Self

Returns the “default value” for a type.