Enum AcquireError 

pub enum AcquireError {
    GlobalExhausted {
        limit: usize,
        current: usize,
    },
    PrincipalExhausted {
        principal: String,
        limit: usize,
        current: usize,
    },
}

Failure modes of StreamCapacityRegistry::try_acquire. Each variant carries the cap that fired and the live counter value at refusal time so clients can back off intelligently (the HTTP layer surfaces these inside the structured 429 body).

Variants

GlobalExhausted

stream.max_global exceeded. Per acceptance criterion #1.

Fields

limit: usize

current: usize

PrincipalExhausted

stream.max_per_principal exceeded for principal. Per acceptance criterion #2. The principal is surfaced verbatim; callers must escape it on the wire.

Fields

principal: String

limit: usize

current: usize

Implementations

impl AcquireError

pub fn code(&self) -> &'static str

pub fn message(&self) -> String

Trait Implementations

impl Clone for AcquireError

fn clone(&self) -> AcquireError

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AcquireError

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

Formats the value using the given formatter.

impl PartialEq for AcquireError

fn eq(&self, other: &AcquireError) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for AcquireError

impl StructuralPartialEq for AcquireError