Struct TaskRateLimiter 

pub struct TaskRateLimiter { /* private fields */ }

Per-task rate limiter manager

Manages rate limiters for multiple task types, allowing different rate limits per task name.

Implementations

impl TaskRateLimiter

pub fn new() -> Self

Create a new task rate limiter manager

pub fn with_default(config: RateLimitConfig) -> Self

Create with a default rate limit for all tasks

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

Set rate limit for a specific task type

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

Remove rate limit for a specific task type

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

Try to acquire a permit for a specific task

Returns true if the task can execute, false if rate limited

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 get_rate_limit(&self, task_name: &str) -> Option<&RateLimitConfig>

Get the rate limit configuration for a task

pub fn reset_all(&mut self)

Reset all rate limiters

Trait Implementations

impl Debug for TaskRateLimiter

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

Formats the value using the given formatter.

impl Default for TaskRateLimiter

fn default() -> Self

Returns the “default value” for a type.