Struct StreamClaimOptions

pub struct StreamClaimOptions { /* private fields */ }

Builder options for xclaim_options command.

Implementations

impl StreamClaimOptions

pub fn idle(self, ms: usize) -> Self

Set IDLE <milliseconds> cmd arg.

pub fn time(self, ms_time: usize) -> Self

Set TIME <Unix epoch milliseconds> cmd arg.

pub fn retry(self, count: usize) -> Self

Set RETRYCOUNT <count> cmd arg.

pub fn with_force(self) -> Self

Set FORCE cmd arg to true.

pub fn with_justid(self) -> Self

Set JUSTID cmd arg to true. Be advised: the response type changes with this option.

pub fn with_lastid(self, lastid: impl Into<String>) -> Self

Set LASTID <lastid> cmd arg.

Trait Implementations

impl Debug for StreamClaimOptions

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

Formats the value using the given formatter.

impl Default for StreamClaimOptions

fn default() -> StreamClaimOptions

Returns the “default value” for a type.

impl ToRedisArgs for StreamClaimOptions

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.