Enum sea_streamer_redis::AutoCommit

pub enum AutoCommit {
    Immediate,
    Delayed,
    Rolling,
    Disabled,
}

The auto ack / commit mechanism.

Variants

Immediate

XREAD with NOACK. This acknowledges messages as soon as they are fetched. In the event of service restart, this will likely result in messages being skipped.

Delayed

Auto ack and commit, but only after auto_commit_delay has passed since messages are read.

This is the default option, because users don’t have to do anything extra. This also mimicks Kafka clients.

Rolling

Do not auto ack, but continually commit acked messages to the server as new messages are read. The consumer will not commit more often than auto_commit_interval. You have to call RedisConsumer::ack manually.

This is the recommended option for achieving ‘at-least-once’ semantics.

Disabled

Never auto ack or commit. You have to call RedisConsumer::ack and RedisConsumer::commit manually.

Trait Implementations

impl Clone for AutoCommit

fn clone(&self) -> AutoCommit

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for AutoCommit

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

Formats the value using the given formatter.

impl PartialEq for AutoCommit

fn eq(&self, other: &AutoCommit) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for AutoCommit

impl Eq for AutoCommit

impl StructuralPartialEq for AutoCommit