Struct StreamInfoGroup

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

A group parsed from xinfo_groups command.

Fields

name: String

The group name.

consumers: usize

Number of consumers known in the group.

pending: usize

Number of pending messages (delivered but not yet acknowledged) in the group.

last_delivered_id: String

Last ID delivered to this group.

entries_read: Option<usize>

The logical “read counter” of the last entry delivered to group’s consumers (or None if the server does not provide the value).

lag: Option<usize>

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

Trait Implementations

impl Clone for StreamInfoGroup

fn clone(&self) -> StreamInfoGroup

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamInfoGroup

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

Formats the value using the given formatter.

impl Default for StreamInfoGroup

fn default() -> StreamInfoGroup

Returns the “default value” for a type.