Struct PerSenderTracker 

pub struct PerSenderTracker { /* private fields */ }

Per-sender sliding-window rate limiter.

Each unique sender key (Telegram thread ID, Discord channel, etc.) gets its own independent ActionTracker bucket. When no sender is in scope (cron jobs, CLI), the GLOBAL_KEY bucket is used.

The bucket map is shared via Arc so a SubAgent policy that clones from its parent observes the same live counts. SubAgent budget inheritance relies on this: a child run consuming an action sees the shared bucket update, so the parent’s max_actions_per_hour ceiling applies across both runs rather than each getting a fresh allocation.

Note: sender buckets accumulate for the daemon lifetime with no eviction. This is acceptable for bounded sets of chat IDs; in high-cardinality deployments, consider periodic cleanup.

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. Allows the action when count == max (≤ max); blocks and returns false when count > max.

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

Check if key is at or over max (without recording). Does NOT insert a bucket for unseen keys. A max of 0 is always exhausted (zero budget means no actions allowed). Returns true when count has reached or exceeded max. Note: acquires write lock because ActionTracker::count prunes stale entries internally. Also note: returns true one count earlier than record_within would block.

Trait Implementations

impl Clone for PerSenderTracker

fn clone(&self) -> Self

Cloning a PerSenderTracker shares the bucket map by Arc. SubAgent runs consume from the same buckets as their parent so per-hour and per-day budgets are not bypassed by spawning children. Tests that need an isolated tracker construct a fresh one via Self::new rather than cloning.

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.