Skip to main content

QueueProducer

Trait QueueProducer 

Source
pub trait QueueProducer {
    type Error;

    // Required method
    fn append(&mut self, record: &[u8]) -> Result<u64, Self::Error>;
}
Expand description

Minimal producer-side contract for a single globally ordered queue.

The producer appends one opaque record payload and receives the queue’s acceptance sequence (ext_seq) back. This is the accepted boundary.

Required Associated Types§

Required Methods§

Source

fn append(&mut self, record: &[u8]) -> Result<u64, Self::Error>

Implementors§