Enum StreamDeletionPolicy

pub enum StreamDeletionPolicy {
    KeepRef,
    DelRef,
    Acked,
}

Deletion policy for stream entries.

Variants

KeepRef

Preserve existing references to the deleted entries in all consumer groups’ PEL.

DelRef

Delete the entry from the stream and from all the consumer groups’ PELs.

Acked

Delete the entry from the stream and from all the consumer groups’ PELs, but only if the entry is acknowledged by all the groups.

Trait Implementations

impl Clone for StreamDeletionPolicy

fn clone(&self) -> StreamDeletionPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamDeletionPolicy

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

Formats the value using the given formatter.

impl Default for StreamDeletionPolicy

fn default() -> StreamDeletionPolicy

Returns the “default value” for a type.

impl ToRedisArgs for StreamDeletionPolicy

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.