Trait BufferStore 

pub trait BufferStore {
    type Error: Error + Send + Sync + 'static;

    // Required methods
    fn push(&mut self, entry: BufferedEntry) -> Result<(), Self::Error>;
    fn entries(&self) -> Result<Vec<BufferedEntry>, Self::Error>;
    fn drop_oldest(&mut self, n: usize) -> Result<(), Self::Error>;
    fn clear(&mut self) -> Result<(), Self::Error>;
    fn len(&self) -> Result<usize, Self::Error>;

    // Provided method
    fn is_empty(&self) -> Result<bool, Self::Error> { ... }
}

Pluggable persistent / volatile storage for OfflineBuffer.

Required Associated Types

type Error: Error + Send + Sync + 'static

Required Methods

fn push(&mut self, entry: BufferedEntry) -> Result<(), Self::Error>

Append an entry to the back of the buffer.

fn entries(&self) -> Result<Vec<BufferedEntry>, Self::Error>

Return all entries in insertion order.

fn drop_oldest(&mut self, n: usize) -> Result<(), Self::Error>

Remove the oldest n entries. If n >= len the buffer is emptied.

fn clear(&mut self) -> Result<(), Self::Error>

Remove every entry.

fn len(&self) -> Result<usize, Self::Error>

Return the current number of buffered entries.

Provided Methods

fn is_empty(&self) -> Result<bool, Self::Error>

Return true when there are no buffered entries.

Implementors

impl BufferStore for InMemoryBufferStore

type Error = InMemoryBufferStoreError