Struct StreamInfoStreamReplyWithIdempotency 

#[non_exhaustive]
pub struct StreamInfoStreamReplyWithIdempotency {
    pub base: StreamInfoStreamReply,
    pub idmp_duration: u32,
    pub idmp_maxsize: u16,
    pub pids_tracked: usize,
    pub iids_tracked: usize,
    pub iids_added: usize,
    pub iids_duplicates: usize,
}

Reply type used with xinfo_stream_with_idempotency command (Redis 8.6+).

This type composes StreamInfoStreamReply with additional idempotency tracking fields introduced in Redis 8.6.

The base stream information is accessible via the base field, while idempotency fields are directly available as top-level fields.

Example

use redis::{Commands, streams::StreamInfoStreamReplyWithIdempotency};

let info: StreamInfoStreamReplyWithIdempotency = con.xinfo_stream_with_idempotency("stream").unwrap();

// Access base stream info
println!("Stream length: {}", info.base.length);
println!("Last ID: {}", info.base.last_generated_id);

// Access idempotency tracking (Redis 8.6+)
println!("Producers tracked: {}", info.pids_tracked);
println!("Idempotent IDs tracked: {}", info.iids_tracked);
println!("Duplicates prevented: {}", info.iids_duplicates);

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

base: StreamInfoStreamReply

Base stream information

idmp_duration: u32

The duration in seconds that idempotent IDs are retained in the stream’s IDMP map

idmp_maxsize: u16

The maximum number of idempotent IDs kept for each producer in the stream’s IDMP map

pids_tracked: usize

The number of unique producer IDs currently being tracked

iids_tracked: usize

The total number of idempotent IDs currently stored across all producers

iids_added: usize

The total count of idempotent IDs that have been added to the stream during its lifetime

iids_duplicates: usize

The total count of duplicate messages that were detected and prevented by IDMP

Trait Implementations

impl Clone for StreamInfoStreamReplyWithIdempotency

fn clone(&self) -> StreamInfoStreamReplyWithIdempotency

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamInfoStreamReplyWithIdempotency

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

Formats the value using the given formatter.

impl Default for StreamInfoStreamReplyWithIdempotency

fn default() -> StreamInfoStreamReplyWithIdempotency

Returns the “default value” for a type.

impl FromRedisValue for StreamInfoStreamReplyWithIdempotency

fn from_redis_value(v: Value) -> Result<Self, ParsingError>

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_value_ref(v: &Value) -> Result<Self, ParsingError>

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_value_refs(items: &[Value]) -> Result<Vec<Self>, ParsingError>

Similar to from_redis_value_ref 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_redis_values(items: Vec<Value>) -> Result<Vec<Self>, ParsingError>

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

fn from_each_redis_values(items: Vec<Value>) -> Vec<Result<Self, ParsingError>>

The same as from_redis_values, but returns a result for each conversion to make handling them case-by-case possible.

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

Convert bytes to a single element vector.

fn from_byte_vec(_vec: Vec<u8>) -> Result<Vec<Self>, ParsingError>

Convert bytes to a single element vector.