Enum Position 

#[non_exhaustive]
pub enum Position<'a> {
    Beginning,
    End,
    Unread,
    SequenceNumber(u64),
    TimeStamp(DateTime<Local>),
    Since(&'a str),
}

Volga Consumer starting position.

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

Get all messages from the beginning.

End

Start consuming from the end, i.e only get new messages.

Unread

Get all unread messages.

SequenceNumber(u64)

Start consuming from a sequence number.

TimeStamp(DateTime<Local>)

Start consuming from a timestamp.

Since(&'a str)

Trait Implementations

impl<'a> Clone for Position<'a>

fn clone(&self) -> Position<'a>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for Position<'a>

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

Formats the value using the given formatter.

impl<'a> Default for Position<'a>

fn default() -> Position<'a>

Returns the “default value” for a type.

impl<'a> Serialize for Position<'a>

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<'a> Copy for Position<'a>