Struct AtomicBudget 

pub struct AtomicBudget { /* private fields */ }

Atomic, lock-free token-bucket budget.

Reference implementation of BudgetGuard. Backed by a single AtomicU64 counter and CAS retries.

Implementations

impl AtomicBudget

pub fn new(capacity: u64) -> Self

Create a budget with the given capacity, initially full.

pub fn capacity(&self) -> u64

Total capacity at construction time.

pub fn available(&self) -> u64

Currently available units.

pub fn utilization(&self) -> f64

Utilization in [0, 1]. Useful for telemetry gauges.

pub fn refill(&self)

Restore the budget to capacity. Typically called at the start of each scheduling epoch.

Trait Implementations

impl BudgetGuard for AtomicBudget

fn try_reserve<'life0, 'async_trait>( &'life0 self, cost: u64, ) -> Pin<Box<dyn Future<Output = Result<bool, BudgetError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Try to reserve cost units of budget for an upcoming operation. Returns Ok(true) on success, Ok(false) on soft denial.

fn release<'life0, 'async_trait>( &'life0 self, cost: u64, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Release previously reserved units back to the pool.

impl Debug for AtomicBudget

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

Formats the value using the given formatter.