Struct PrincipalConnectionLimiter 

pub struct PrincipalConnectionLimiter { /* private fields */ }

Implementations

impl PrincipalConnectionLimiter

pub fn new(cap: usize) -> Self

Build a limiter with the given per-principal concurrent in-flight cap. 0 disables enforcement.

pub fn cap(&self) -> usize

The configured per-principal cap. 0 means disabled.

pub fn is_enforced(&self) -> bool

true when enforcement is active (cap > 0).

pub fn current_for(&self, principal: &str) -> usize

Live in-flight count for a single principal (0 if it holds none). Observability only.

pub fn tracked_principals(&self) -> usize

Number of principals currently holding at least one permit.

pub fn rejected_total(&self) -> u64

Total refusals issued since construction. Surfaced via reddb_http_principal_inflight_rejected_total.

pub fn try_acquire( &self, principal: &str, ) -> Result<PrincipalInflightPermit, PrincipalCapExceeded>

Admit one in-flight request for principal. Returns Ok(permit) when the principal is under its cap (slot reserved, released on permit drop) or Err(PrincipalCapExceeded) when it is already at the cap. A disabled limiter (cap 0) always admits and never touches the map.

Trait Implementations

impl Clone for PrincipalConnectionLimiter

fn clone(&self) -> PrincipalConnectionLimiter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PrincipalConnectionLimiter

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

Formats the value using the given formatter.