Struct ConsumerStateView 

pub struct ConsumerStateView {
    pub consumer: ConsumerId,
    pub current_in_flight: u32,
    pub max_in_flight: u32,
    pub buffer_depth: u32,
    pub affinity_tags: Vec<String>,
}

Per-consumer state presented to a routing function during execution.

Fields

consumer: ConsumerId

Consumer the state describes.

current_in_flight: u32

Messages currently in flight to the consumer.

max_in_flight: u32

Maximum messages the consumer will accept in flight.

buffer_depth: u32

Depth of the consumer’s pending buffer.

affinity_tags: Vec<String>

Affinity tags advertised by the consumer.

Implementations

impl ConsumerStateView

pub const fn new( consumer: ConsumerId, current_in_flight: u32, max_in_flight: u32, buffer_depth: u32, affinity_tags: Vec<String>, ) -> Self

Creates a consumer state view.

pub const fn available_capacity(&self) -> u32

Returns the remaining in-flight capacity of the consumer.

pub const fn has_capacity(&self) -> bool

Returns true when the consumer can accept at least one more message.

pub fn has_affinity(&self, tag: &str) -> bool

Returns true when the consumer advertises tag.

Trait Implementations

impl Clone for ConsumerStateView

fn clone(&self) -> ConsumerStateView

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerStateView

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

Formats the value using the given formatter.

impl Eq for ConsumerStateView

impl PartialEq for ConsumerStateView

fn eq(&self, other: &ConsumerStateView) -> 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 ConsumerStateView