Struct ConsumerCapacity 

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

Consumer-declared capacity limits for pressure-aware delivery.

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) -> ConsumerCapacity

Returns a duplicate of the value.

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

Performs copy-assignment from source.

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: &ConsumerCapacity) -> 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 StructuralPartialEq for ConsumerCapacity