Struct UsageBuffer 

pub struct UsageBuffer { /* private fields */ }

Thread-safe in-memory aggregator with bounded idempotency memory.

Implementations

impl UsageBuffer

pub fn new(max_idempotency_keys: usize) -> UsageBuffer

Construct a buffer retaining at most max_idempotency_keys once-only keys. Zero disables in-process deduplication.

pub fn record(&self, event: UsageEvent) -> Result<RecordOutcome, RecordError>

Record one event into a (customer, meter) aggregate.

Errors

Returns RecordError::Poisoned if another thread panicked while mutating the buffer, or RecordError::UnitsOverflow rather than silently saturating an invoice quantity.

pub fn retry_buckets(&self) -> usize

Number of aggregates waiting to be retried.

Separated from Self::pending_buckets because the two mean very different things operationally: pending rising means traffic, retry rising means the provider is refusing, and a retry count that never falls is a batch that will never be accepted.

pub fn pending_buckets(&self) -> usize

Number of live aggregate buckets plus retry events.

Trait Implementations

impl Debug for UsageBuffer

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

Formats the value using the given formatter.

impl Default for UsageBuffer

fn default() -> UsageBuffer

Returns the “default value” for a type.