Struct RateLimiterHandle 

pub struct RateLimiterHandle {
    pub metrics: Arc<Metrics>,
    /* private fields */
}

Handle to communicate with the rate limiter actor

This handle can be cloned and shared across multiple tasks/threads. All operations are async and non-blocking.

Fields

metrics: Arc<Metrics>

Implementations

impl RateLimiterHandle

pub async fn throttle( &self, request: ThrottleRequest, ) -> Result<ThrottleResponse>

Check rate limit for a key

Sends a throttle request to the actor and waits for the response. This method is cancel-safe and can be used in select! expressions.

Errors

Returns an error if:

• The actor has shut down
• The response channel was dropped

Trait Implementations

impl Clone for RateLimiterHandle

fn clone(&self) -> RateLimiterHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.