Struct ConsumerCapacity 

pub struct ConsumerCapacity {
    pub max_in_flight: usize,
    pub max_buffer_depth: usize,
}

Consumer-declared capacity limits for pressure-aware delivery.

Copy because it is two usizes: it is passed by value through the admission path and the depth-cap clamp, and cloning a pair of integers to read them is noise. Additive.

Fields

max_in_flight: usize

Maximum messages this consumer can process concurrently.

max_buffer_depth: usize

Maximum messages that may wait for this consumer’s capacity to free.

Implementations

impl ConsumerCapacity

pub const fn new( max_in_flight: usize, max_buffer_depth: usize, ) -> Result<Self, CapacityError>

Creates a capacity declaration after verifying both limits are positive.

Errors

Returns CapacityError::InvalidCapacity when either declared limit is zero.

pub const fn validate(&self) -> Result<(), CapacityError>

Verifies that the declared capacity contains positive limits.

Errors

Returns CapacityError::InvalidCapacity when either declared limit is zero.

Trait Implementations

impl Clone for ConsumerCapacity

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for ConsumerCapacity

impl Debug for ConsumerCapacity

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

Formats the value using the given formatter.

impl Eq for ConsumerCapacity

impl PartialEq for ConsumerCapacity

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ConsumerCapacity