Struct ConsumerInfo 

pub struct ConsumerInfo {
    pub name: String,
    pub stream_name: String,
    pub delivered: u64,
    pub ack_pending: u64,
    pub redelivered: u64,
    pub num_waiting: u64,
}

Consumer information and statistics

Fields

name: String

Consumer name

stream_name: String

Stream name this consumer is attached to

delivered: u64

Number of messages delivered

ack_pending: u64

Number of messages pending acknowledgment

redelivered: u64

Number of messages redelivered

num_waiting: u64

Number of messages waiting to be delivered

Implementations

impl ConsumerInfo

pub fn is_healthy(&self) -> bool

Check if the consumer is healthy (not backed up with unacked messages)

Trait Implementations

impl Clone for ConsumerInfo

fn clone(&self) -> ConsumerInfo

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerInfo

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

Formats the value using the given formatter.