Struct PendingStats

pub struct PendingStats {
    pub len: u64,
    pub lowest_id: StreamId,
    pub highest_id: StreamId,
    pub consumers: Vec<PendingConsumerStat>,
}

Brief output of XPENDING

Provided when no ID is specified in arguments

Fields

len: u64

Number of pending messages within group

If len is 0, rest of fields are using default values.

lowest_id: StreamId

Smallest ID among pending messages

highest_id: StreamId

Highest ID among pending messages

consumers: Vec<PendingConsumerStat>

Stats on every consumer within group

Trait Implementations

impl FromRedisValue for PendingStats

fn from_redis_value(value: &Value) -> Result<Self, RedisError>

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_owned_redis_value(v: Value) -> Result<Self, RedisError>

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_owned_redis_values(items: Vec<Value>) -> Result<Vec<Self>, RedisError>

The same as from_redis_values, but takes a Vec<Value> instead of a &[Value].

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

Convert bytes to a single element vector.

fn from_owned_byte_vec(_vec: Vec<u8>) -> Result<Vec<Self>, RedisError>

Convert bytes to a single element vector.