Struct rustis::commands::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<'de> Deserialize<'de> for XGroupInfo

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.