Struct ConsumerGroup 

pub struct ConsumerGroup {
    pub last_delivered_id: StreamId,
    pub pel: BTreeMap<StreamId, PelEntry>,
    pub consumers: KevyMap<SmallBytes, Box<ConsumerState>>,
}

One consumer group’s state. Sorted PEL plus a map of known consumers (with cached pel_count for O(1) XINFO answers).

Fields

last_delivered_id: StreamId

Highest ID delivered to any consumer in this group. Bumped by XREADGROUP with >; settable via XGROUP SETID.

pel: BTreeMap<StreamId, PelEntry>

Pending-Entries List: every ID delivered but not yet ACKed. Sorted by ID for XPENDING start end range queries.

consumers: KevyMap<SmallBytes, Box<ConsumerState>>

Consumers known to this group (by name).

Implementations

impl ConsumerGroup

pub fn last_delivered_id(&self) -> StreamId

Highest ID delivered by this group — for XINFO GROUPS.

pub fn pending_count(&self) -> usize

Total pending entries — XINFO GROUPS’s pending.

pub fn consumer_count(&self) -> usize

Known consumer count — XINFO GROUPS’s consumers.

pub fn consumers_iter(&self) -> impl Iterator<Item = (&[u8], &ConsumerState)>

Iterate (consumer_name, consumer) pairs — XINFO CONSUMERS.

Trait Implementations

impl Clone for ConsumerGroup

fn clone(&self) -> ConsumerGroup

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for ConsumerGroup

fn default() -> Self

Returns the “default value” for a type.