Enum RedisGroupPosition 

#[non_exhaustive]
pub enum RedisGroupPosition {
    Beginning,
    End,
    After(EntryId),
}

Where a consumer group’s cursor sits, for RedisGroupSeeker::seek and the start_at(..) clause of #[subscriber].

The cursor is group-wide: it belongs to the consumer group, not to one subscription, so moving it moves it for every consumer reading that group.

Examples

use ruststream_fred::{EntryId, RedisGroupPosition};

let replay_all = RedisGroupPosition::beginning();
let skip_backlog = RedisGroupPosition::end();
let resume = RedisGroupPosition::after("1700000000000-4".parse::<EntryId>()?);

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Beginning

The oldest entry the stream still retains: the group replays everything it holds.

End

The tail: only entries added after the seek are delivered.

After(EntryId)

The first entry after id. The cursor is exclusive, exactly like the id argument of XGROUP SETID, so the entry at id itself is not delivered again.

Implementations

impl RedisGroupPosition

pub const fn beginning() -> Self

The oldest retained entry. Constructor form of Beginning.

pub const fn end() -> Self

Only entries added from now on. Constructor form of End.

pub const fn after(id: EntryId) -> Self

Resume with the entry following id. Constructor form of After.

Trait Implementations

impl Clone for RedisGroupPosition

fn clone(&self) -> RedisGroupPosition

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for RedisGroupPosition

impl Debug for RedisGroupPosition

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

Formats the value using the given formatter.

impl Eq for RedisGroupPosition

impl PartialEq for RedisGroupPosition

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for RedisGroupPosition