Struct PerSenderTracker 

pub struct PerSenderTracker { /* private fields */ }

Per-sender sliding-window rate limiter. The bucket map is Arc-shared so cloned policies (SubAgents) consume from the same budgets.

Implementations

impl PerSenderTracker

pub const GLOBAL_KEY: &'static str = "__global__"

Bucket key used when no per-sender context is available (cron, CLI).

pub fn new() -> Self

Create an empty tracker with no sender buckets.

pub fn record_for_current(&self, max: u32) -> bool

Record one action for the current sender. Returns true if allowed (count after recording <= max), false if budget exhausted.

pub fn record_within(&self, key: &str, max: u32) -> bool

Record one action for key when a slot remains. Rejected attempts are not recorded.

pub fn reserve_for_current(&self, max: u32) -> Option<ActionReservation>

Atomically reserve one action slot for the current sender.

pub fn is_limited_for_current(&self, max: u32) -> bool

Check if the current sender is at or over the limit (without recording).

pub fn is_exhausted(&self, key: &str, max: u32) -> bool

Trait Implementations

impl Clone for PerSenderTracker

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PerSenderTracker

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

Formats the value using the given formatter.

impl Default for PerSenderTracker

fn default() -> Self

Returns the “default value” for a type.