Struct XGroupInfo 

pub struct XGroupInfo {
    pub name: String,
    pub consumers: usize,
    pub pending: usize,
    pub last_delivered_id: String,
    pub entries_read: Option<usize>,
    pub lag: Option<usize>,
}

Result entry for the xinfo_groups command.

Fields

name: String

the consumer group’s name

consumers: usize

the number of consumers in the group

pending: usize

the length of the group’s pending entries list (PEL), which are messages that were delivered but are yet to be acknowledged

last_delivered_id: String

the ID of the last entry delivered the group’s consumers

entries_read: Option<usize>

the logical “read counter” of the last entry delivered to group’s consumers

lag: Option<usize>

the number of entries in the stream that are still waiting to be delivered to the group’s consumers, or a NULL when that number can’t be determined.

Trait Implementations

impl FromValue for XGroupInfo

fn from_value(value: Value) -> Result<Self>

Used to do Value to user type conversion

fn from_value_with_command(value: Value, _command: &Command) -> Result<Self>

fn next_functor<I: Iterator<Item = Value>>() -> Box<dyn FnMut(&mut I) -> Option<Result<Self>>>