Trait QueueConsumer 

pub trait QueueConsumer {
    type Record;
    type Error;

    // Required methods
    fn poll(&mut self) -> Result<Option<QueueRecord<Self::Record>>, Self::Error>;
    fn commit_through(&mut self, ext_seq: u64) -> Result<(), Self::Error>;
}

Consumer-side contract for a single globally ordered queue.

Required Associated Types

type Record

Opaque record payload type.

type Error

Queue error type.

Required Methods

fn poll(&mut self) -> Result<Option<QueueRecord<Self::Record>>, Self::Error>

Polls the next source record if one is available.

fn commit_through(&mut self, ext_seq: u64) -> Result<(), Self::Error>

Advances the durable consumed boundary through ext_seq.

Implementors