Struct StreamPendingData

pub struct StreamPendingData {
    pub count: usize,
    pub start_id: String,
    pub end_id: String,
    pub consumers: Vec<StreamInfoConsumer>,
}

Inner reply type when an xpending command has data.

Fields

count: usize

Limit on the number of messages to return per call.

start_id: String

ID for the first pending record.

end_id: String

ID for the final pending record.

consumers: Vec<StreamInfoConsumer>

Every consumer in the consumer group with at least one pending message, and the number of pending messages it has.

Trait Implementations

impl Clone for StreamPendingData

fn clone(&self) -> StreamPendingData

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for StreamPendingData

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

Formats the value using the given formatter.

impl Default for StreamPendingData

fn default() -> StreamPendingData

Returns the “default value” for a type.