Enum StreamIdempotencyMode 

pub enum StreamIdempotencyMode {
    Manual {
        producer_id: String,
        idempotent_id: String,
    },
    Automatic {
        producer_id: String,
    },
}

Idempotency mode for stream message production

Supports idempotent message processing to prevent duplicate entries. See Redis Streams Idempotency

Variants

Manual

Manual mode: Producer provides both producer ID (pid) and idempotent ID (iid)

Example: XADD key IDMP producer-1 iid-1 * field value

Fields

producer_id: String

Producer ID - unique identifier for the message producer

idempotent_id: String

Idempotent ID - unique identifier for this specific message

Automatic

Automatic mode: Producer provides only producer ID (pid), Redis generates iid from message content

Example: XADD key IDMPAUTO producer-1 * field value

Fields

producer_id: String

Producer ID - unique identifier for the message producer

Trait Implementations

impl Clone for StreamIdempotencyMode

fn clone(&self) -> StreamIdempotencyMode

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamIdempotencyMode

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

Formats the value using the given formatter.

impl ToRedisArgs for StreamIdempotencyMode

fn write_redis_args<W>(&self, out: &mut W)

where W: ?Sized + RedisWrite,

This writes the value into a vector of bytes. Each item is a single argument. Most items generate a single item.

fn to_redis_args(&self) -> Vec<Vec<u8>>

This converts the value into a vector of bytes. Each item is a single argument. Most items generate a vector of a single item.

fn describe_numeric_behavior(&self) -> NumericBehavior

Returns an information about the contained value with regards to it’s numeric behavior in a redis context. This is used in some high level concepts to switch between different implementations of redis functions (for instance INCR vs INCRBYFLOAT).

fn num_of_args(&self) -> usize

Returns the number of arguments this value will generate.