Struct ConsumerState 

pub struct ConsumerState {
    pub name: SmallBytes,
    pub last_seen_ms: u64,
    pub pel_count: usize,
}

Per-consumer cached counters so XINFO CONSUMERS answers in O(1).

Fields

name: SmallBytes

Consumer name. Read by XINFO CONSUMERS (sprint C).

last_seen_ms: u64

Last wall-clock (unix-ms) the consumer interacted with the group (any XREADGROUP / XACK / XCLAIM touch).

pel_count: usize

Cached size of this consumer’s slice of the PEL.

Implementations

impl ConsumerState

pub fn pending_count(&self) -> usize

XINFO CONSUMERS’ pending field.

pub fn last_seen_ms(&self) -> u64

Last unix-ms this consumer interacted with the group.

Trait Implementations

impl Clone for ConsumerState

fn clone(&self) -> ConsumerState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerState

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

Formats the value using the given formatter.