Struct redis_queue::types::GroupInfo

pub struct GroupInfo {
    pub name: String,
    pub consumers: u64,
    pub pending: u64,
    pub last_delivered_id: StreamId,
}

Group information

Fields

name: String

Group name

consumers: u64

Number of consumers in the group

pending: u64

Number of messages that are read but yet to be acknowledged.

last_delivered_id: StreamId

ID of last message delivered to group’s consumers

Trait Implementations

impl Debug for GroupInfo

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

Formats the value using the given formatter.

impl FromRedisValue for GroupInfo

fn from_redis_value(value: &Value) -> RedisResult<Self>

Given a redis Value this attempts to convert it into the given destination type. If that fails because it’s not compatible an appropriate error is generated.

fn from_redis_values(items: &[Value]) -> Result<Vec<Self>, RedisError>

Similar to from_redis_value but constructs a vector of objects from another vector of values. This primarily exists internally to customize the behavior for vectors of tuples.

fn from_byte_vec(_vec: &[u8]) -> Option<Vec<Self>>

Convert bytes to a single element vector.