Struct GlobalCounters 

pub struct GlobalCounters { /* private fields */ }

Cross-instance counter reconciliation over a shared Redis-protocol store.

Implementations

impl GlobalCounters

pub fn build(url: &str, interval: Duration) -> Result<Arc<Self>, String>

Open the shared store and return the reconciler.

Errors

Returns the underlying error when the store URL is invalid.

pub fn fleet_remaining(&self, key: &str, budget: u64, window: Duration) -> u64

Fleet budget still available for key (0 = over budget). Read-only: the cached remote estimate plus this instance’s unclaimed count, subtracted from budget. Does not touch the store and does not record the admit (call record after the local check also passes).

This is deliberately a read then a separate record, not an atomic reserve/rollback. The per-instance GcraStore is the hard local cap and is atomic per key; this fleet gate is only an approximate cross-instance cap. A race where concurrent requests all pass the gate before any records is bounded by the local burst plus the documented one-interval overshoot, which is the accepted trade-off for keeping the hot path lock-free and non-blocking.

pub fn record(&self, key: &str, window: Duration)

Record one admitted request for key, to be pushed to the store on the next background tick.

pub fn spawn(self: &Arc<Self>) -> bool

Spawn the background reconciliation loop. Returns false (without spawning) when called outside a Tokio runtime, so the caller can drop the fleet gate and fall back to per-instance limiting rather than gating on a view that would never be reconciled.