Struct LogFileJournalRx

pub struct LogFileJournalRx {
    tx: Option<LogFileJournalTx>,
    buffer_pos: Mutex<usize>,
    buffer: OwnedBuffer,
    store: OffloadBackingStore,
}

Fields

tx: Option<LogFileJournalTx>

buffer_pos: Mutex<usize>

buffer: OwnedBuffer

store: OffloadBackingStore

Implementations

impl LogFileJournalRx

pub fn owned_buffer(&self) -> OwnedBuffer

pub fn backing_store(&self) -> OffloadBackingStore

Trait Implementations

impl Debug for LogFileJournalRx

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

Formats the value using the given formatter.

impl ReadableJournal for LogFileJournalRx

fn read(&self) -> Result<Option<LogReadResult<'_>>, Error>

UNSAFE: This method uses unsafe operations to remove the need to zero the buffer before its read the log entries into it

fn as_restarted(&self) -> Result<Box<dyn ReadableJournal + Send + Sync>, Error>

Resets the journal so that reads will start from the beginning again