Struct TokenBucket 

pub struct TokenBucket { /* private fields */ }

Token bucket rate limiter

Implementations

impl TokenBucket

pub fn new(config: RateLimiterConfig) -> Self

Create a new token bucket with the given configuration

pub fn with_metrics( config: RateLimiterConfig, metrics: Arc<dyn Metrics>, ) -> Self

Create a new token bucket with metrics collection

pub fn set_enabled(&self, enabled: bool)

Enable or disable the rate limiter

pub async fn acquire(&self, tokens: u64) -> Result<(), RateLimitError>

Acquire the specified number of tokens

pub fn tokens(&self) -> u64

Get current token count

pub fn get_metrics(&self) -> RateLimiterMetrics

Get comprehensive metrics

pub fn success_rate(&self) -> f64

Get success rate as a percentage

pub fn rejection_rate(&self) -> f64

Get rejection rate as a percentage

pub fn adjust_rate(&self, success: bool)

Adjust adaptive rate based on success/failure patterns

pub fn reset_adaptive_rate(&self)

Reset adaptive rate to initial value

pub fn set_adaptive_rate(&self, rate: u64)

Set adaptive rate manually

pub fn is_healthy(&self) -> bool

Check if rate limiter is healthy

pub fn reset(&self)

Reset all counters