Trait paxakos::buffer::Buffer

pub trait Buffer: Send + 'static {
    type RoundNum: RoundNum;
    type CoordNum: CoordNum;
    type Entry: LogEntry;
    type Error: Error + Send + Sync + 'static;

    fn insert(
        &mut self, 
        round_num: Self::RoundNum, 
        coord_num: Self::CoordNum, 
        entry: Arc<Self::Entry>
    );
    fn get(
        &self, 
        round_num: Self::RoundNum
    ) -> Result<Option<(Self::CoordNum, Arc<Self::Entry>)>, Self::Error>;
}

A buffer of entries that were applied to the local state.

Required Associated Types

type RoundNum: RoundNum

The round number type.

type CoordNum: CoordNum

The coordination number type.

type Entry: LogEntry

The log entry type.

type Error: Error + Send + Sync + 'static

The type of error this buffer may raise.

Required Methods

fn insert(
    &mut self,
    round_num: Self::RoundNum,
    coord_num: Self::CoordNum,
    entry: Arc<Self::Entry>
)

Insert an applied entry into the buffer.

fn get(
    &self,
    round_num: Self::RoundNum
) -> Result<Option<(Self::CoordNum, Arc<Self::Entry>)>, Self::Error>

Retrieve an entry from the buffer.

May be called for round numbers that were not previously inserted.

Implementors

impl<R, C, E> Buffer for InMemoryBuffer<R, C, E> where
    R: RoundNum,
    C: CoordNum,
    E: LogEntry, 

type RoundNum = R

type CoordNum = C

type Entry = E

type Error = Infallible