Struct RateLeaseKernel 

pub struct RateLeaseKernel { /* private fields */ }

An in-process registry of RateLeases, keyed by an opaque subject string (the §72.c dispatch gate composes the key from the budget’s scope + the effect + the quota kind, e.g. "daemon:Outbound:Tool(TelnyxCall):rate"). This is the OSS single-replica reference; the §72.e enterprise layer binds the per-tenant Redis RateLimiter for multi-replica enforcement.

Implementations

impl RateLeaseKernel

pub fn new() -> Self

pub fn register(&mut self, key: impl Into<String>, lease: RateLease)

Register (or replace) the lease for key.

pub fn contains(&self, key: &str) -> bool

Whether a lease is registered for key.

pub fn try_acquire(&mut self, key: &str, now: DateTime<Utc>) -> AcquireOutcome

Attempt to consume one token from the lease at key. A key with no registered lease is unbudgeted ⇒ always AcquireOutcome::Granted (an effect with no declared quota is not rate-limited).

pub fn try_acquire_all( &mut self, keys: &[String], now: DateTime<Utc>, ) -> AcquireOutcome

Attempt to consume one token from EVERY lease in keys, all-or-none: consumes from all only if all have a token (so a per-hour rate and a per-day max on the same tool both gate the call without a partial consumption when one is exhausted). Returns AcquireOutcome::Denied with the LATEST retry_at among the exhausted leases (the binding constraint — you must wait for the slowest). An empty keys (an unbudgeted effect) is granted. Unknown keys are skipped (treated as unbudgeted).

pub fn available(&self, key: &str, now: DateTime<Utc>) -> Option<f64>

Tokens currently available at key (None if unregistered).

pub fn tick(&mut self, now: DateTime<Utc>)

Housekeeping pass — refill/roll every registered lease to now so available snapshots are fresh. The refilling analogue of the lease kernel’s sweep. Acquisition does not depend on this (refill is lazy).

pub fn snapshot(&self) -> Vec<(String, RateLeaseSnapshot)>

§Fase 72.e — snapshot every lease’s state as (key, snapshot) pairs for persistence. Deterministic order (sorted by key).

pub fn restore(&mut self, snaps: &[(String, RateLeaseSnapshot)])

§Fase 72.e — restore lease states from (key, snapshot) pairs. Keys with no registered lease are skipped (a quota dropped from a re-budgeted daemon).

Trait Implementations

impl Default for RateLeaseKernel

fn default() -> RateLeaseKernel

Returns the “default value” for a type.