Struct CompactingLogFileJournalTx

pub struct CompactingLogFileJournalTx {
    state: Arc<Mutex<State>>,
    inner: CompactingJournalTx,
    main_path: PathBuf,
    temp_path: PathBuf,
}

Fields

state: Arc<Mutex<State>>

inner: CompactingJournalTx

main_path: PathBuf

temp_path: PathBuf

Implementations

impl CompactingLogFileJournalTx

pub fn compact_now(&self) -> Result<(CompactResult, CompactingJournalRx), Error>

pub fn reset_counters(&self)

Trait Implementations

impl Debug for CompactingLogFileJournalTx

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

Formats the value using the given formatter.

impl Drop for CompactingLogFileJournalTx

fn drop(&mut self)

Executes the destructor for this type.

impl WritableJournal for CompactingLogFileJournalTx

fn write<'a>(&'a self, entry: JournalEntry<'a>) -> Result<LogWriteResult, Error>

Takes in a stream of snapshot log entries and saves them so that they may be restored at a later moment

fn flush(&self) -> Result<(), Error>

Flushes the data to disk or network

fn commit(&self) -> Result<usize, Error>

Commits the transaction Returns the number of events committed

fn rollback(&self) -> Result<usize, Error>

Rolls back the transaction and aborts its changes Returns the number of events rolled back