Struct persist::unreliable::UnreliableLog

pub struct UnreliableLog<L> {
    handle: UnreliableHandle,
    log: L,
}

An unreliable delegate to Log.

Fields

handle: UnreliableHandle

log: L

Implementations

impl<L: Log> UnreliableLog<L>

pub fn new(log: L) -> (Self, UnreliableHandle)

Returns a new UnreliableLog and a handle for controlling it.

pub fn from_handle(log: L, handle: UnreliableHandle) -> Self

Returns a new UnreliableLog sharing the given handle.

Trait Implementations

impl<L: Debug> Debug for UnreliableLog<L>

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

Formats the value using the given formatter.

impl<L: Log> Log for UnreliableLog<L>

fn write_sync(&mut self, buf: Vec<u8>) -> Result<SeqNo, Error>

Synchronously appends an entry.

fn snapshot<F>(&self, logic: F) -> Result<Range<SeqNo>, Error> where
    F: FnMut(SeqNo, &[u8]) -> Result<(), Error>, 

Returns a consistent snapshot of all written but not yet truncated entries.

fn truncate(&mut self, upper: SeqNo) -> Result<(), Error>

Removes all entries with a SeqNo strictly less than the given upper bound.

fn close(&mut self) -> Result<bool, Error>

Synchronously closes the log, releasing exclusive-writer locks and causing all future commands to error.