Struct HttpConnectionLimiter 

pub struct HttpConnectionLimiter { /* private fields */ }

Implementations

impl HttpConnectionLimiter

pub fn new(cap: usize) -> HttpConnectionLimiter

pub fn with_clock( cap: usize, clock: Arc<dyn MonotonicClock>, ) -> HttpConnectionLimiter

Construct with an explicit clock. Production uses [new], which wires the real monotonic clock; tests inject a fake to drive the rejection-rate derivation deterministically.

pub fn with_default_cap() -> HttpConnectionLimiter

Default cap: (2 * available_parallelism).clamp(8, 256).

pub fn cap(&self) -> usize

pub fn current(&self) -> usize

pub fn try_acquire(&self) -> Option<HttpConnectionPermit>

Returns Some(permit) on success, None if the cap is full. No blocking, no allocation on the hot path.

pub fn rejected_since_last_observe(&self) -> u64

Rejections accumulated since the last observe. Read-only: it accumulates monotonically within a window and is reset only by observe.

pub fn observe(&self) -> LimiterObservation

Snapshot-and-reset the rejection window: returns the rejections since the previous observe together with the elapsed wall and the derived per-second rate, then resets the counter and arms the next window at the current clock reading. rejections_per_sec is 0.0 when no time has elapsed (avoids a divide-by-zero on back-to-back observes).

Trait Implementations

impl Clone for HttpConnectionLimiter

fn clone(&self) -> HttpConnectionLimiter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HttpConnectionLimiter

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

Formats the value using the given formatter.