Struct TokenBucket 

pub struct TokenBucket { /* private fields */ }

A std-only token bucket for the tree-wide spawn-rate cap (8 burst, 2 tokens/s by default). Hand-rolled — a rate limiter is Instant + arithmetic, never a crate. Refill is lazy: every try_take first credits the tokens that have accrued since the last call, then spends one if it can. This catches a fast churn loop that stays under the absolute subagent count — a wedged child hammering subagent.spawn just keeps getting refusals.

Implementations

impl TokenBucket

pub fn new(burst: u32, per_sec: f64) -> TokenBucket

A bucket that starts full (burst tokens) and refills per_sec tokens each second up to burst.

pub fn try_take_at(&mut self, now: Instant) -> bool

Lazy-refill to now, then spend one token if one is available. Returns whether a token was taken (i.e. whether the spawn may proceed). now is explicit so the refill is deterministically unit-testable; last only ever moves forward (a non-monotonic now simply adds no tokens).

pub fn try_take(&mut self) -> bool

Spend one token against the wall clock (the production entry point).

Trait Implementations

impl Clone for TokenBucket

fn clone(&self) -> TokenBucket

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for TokenBucket

impl Debug for TokenBucket

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

Formats the value using the given formatter.