Struct AtomicStorage 

pub struct AtomicStorage(/* private fields */);

Thread-safe atomic storage implementation.

Uses atomic operations for concurrent access to token bucket state. Suitable for multi-threaded scenarios where multiple threads need to access the same token bucket.

Examples

use gardal::{TokenBucket, Limit, AtomicStorage, StdClock};
use std::num::NonZeroU32;

let limit = Limit::per_second(NonZeroU32::new(100).unwrap());
let bucket = TokenBucket::<AtomicStorage, _>::new(limit, StdClock);

Trait Implementations

impl Debug for AtomicStorage

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

Formats the value using the given formatter.

impl TimeStorage for AtomicStorage

fn new(zero_time: f64) -> Self

Create a new storage policy with the provided zero time.

fn load(&self) -> f64

Load the current zero time.

fn store(&self, value: f64)

Store the zero time.

fn compare_exchange_weak(&self, current: f64, new: f64) -> Result<(), f64>

Compare and exchange the zero time.