Struct StreamCapacityRegistry 

pub struct StreamCapacityRegistry { /* private fields */ }

Issue #761 / S2 — process-wide stream capacity registry. Holds two counters: a global concurrent-stream count and a per-principal map. Both are decremented when the StreamCapacityGuard handed back from a successful try_acquire is dropped, so the release path covers every normal exit (success, mid-stream error, snapshot expiry, client disconnect that drops the writer chain, panic unwind through the stack frame holding the guard).

Implementations

impl StreamCapacityRegistry

pub fn new() -> Arc<StreamCapacityRegistry>

pub fn try_acquire( self: &Arc<StreamCapacityRegistry>, principal: &str, max_global: usize, max_per_principal: usize, ) -> Result<StreamCapacityGuard, AcquireError>

Attempt to acquire one slot. Both caps are checked under the same lock, so a concurrent acquire+release pair cannot over- issue beyond either ceiling (acceptance criterion #5).

pub fn snapshot(&self) -> (usize, HashMap<String, usize>)

Visible for tests and audit handlers.

Trait Implementations

impl Debug for StreamCapacityRegistry

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

Formats the value using the given formatter.

impl Default for StreamCapacityRegistry

fn default() -> StreamCapacityRegistry

Returns the “default value” for a type.