Struct ratelimit_meter::Threadsafe

pub struct Threadsafe<Impl> where
    Impl: Sized,
    Impl: Clone,  { /* fields omitted */ }

A wrapper that ensures operations in otherwise thread-unsafe rate-limiting decision algorithms are thread-safe. This is implemented by wrapping the actual Decider implementation in an atomically reference-counted mutex. It takes out a mutex whenever .test_and_update() is called.

Trait Implementations

impl<Impl: Clone> Clone for Threadsafe<Impl> where
    Impl: Sized,
    Impl: Clone, 

fn clone(&self) -> Threadsafe<Impl>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<Impl> DeciderImpl for Threadsafe<Impl> where
    Impl: Decider,
    Impl: Sized,
    Impl: Clone, 

type T = Impl::T

The (optional) type for additional information on negative decisions.

fn test_and_update(&mut self, at: Instant) -> Result<Decision<Impl::T>>

Tests if a single cell can be accomodated in the rate limiter at the instant at and updates the rate-limiter to account for the weight of the cell.

fn build_with(l: &Limiter) -> Result<Self>

Converts the limiter builder into a concrete decider structure.

impl<Impl> Decider for Threadsafe<Impl> where
    Impl: Decider,
    Impl: Sized,
    Impl: Clone, 

fn check(&mut self) -> Result<Decision<Self::T>>

Tests if a single cell can be accomodated at Instant::now(). See check_at.

fn check_at(&mut self, at: Instant) -> Result<Decision<Self::T>>

Tests is a single cell can be accomodated at the given time stamp.