Enum avassa_client::volga::consumer::Position

pub enum Position {
    Beginning,
    End,
    Unread,
    SequenceNumber(u64),
    TimeStamp(DateTime<Local>),
}

Volga Consumer starting position

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

Trait Implementations

impl Clone for Position

fn clone(&self) -> Position

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Position

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

Formats the value using the given formatter.

impl Default for Position

fn default() -> Self

Returns the “default value” for a type.

impl Serialize for Position

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

Serialize this value into the given Serde serializer.

impl Copy for Position