Struct Limiter 

pub struct Limiter { /* private fields */ }

Per-channel adaptive limiter.

Cheap to clone — both fields are Arc. Pass clones into hot loops; do not hold the lock across .await points (call sites observe with short critical sections only).

Implementations

impl Limiter

pub fn new(start: usize, config: LimiterConfig) -> Self

Create a new limiter starting at start, clamped into [min_concurrency, max_concurrency]. Sanitizes the config to guard against directly-constructed LimiterConfig literals with hostile float values (NaN, etc).

pub fn current(&self) -> usize

Snapshot current concurrency cap. Hot-path call: the value may change between this call and the next, but consumers (buffer_unordered(n)) capture it once per pipeline build.

pub fn observe(&self, outcome: Outcome, latency: Duration)

Record one observed operation. Updates the sliding window and re-evaluates the cap if the window is full enough.

pub fn warm_start(&self, start: usize)

Replace the current cap with start, clamped. Used for warm loads from persisted state. Marks the limiter as having already-left-slow-start so a single healthy window doesn’t double the cap (an over-aggressive cold-start from a warm value). Subsequent increases are +1 per healthy window. Does not clear the sliding window — fresh observations remain authoritative for adaptation decisions.

pub fn snapshot(&self) -> usize

Snapshot of the current cap for persistence. Cheap, lock-only.

Trait Implementations

impl Clone for Limiter

fn clone(&self) -> Limiter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Limiter

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

Formats the value using the given formatter.