Struct rustdb::atomfile::BasicAtomicFile

pub struct BasicAtomicFile {
    pub stg: Box<dyn Storage>,
    pub upd: Box<dyn Storage>,
    /* private fields */
}

Non-buffered alternative to AtomicFile.

Fields

stg: Box<dyn Storage>

The main underlying storage.

upd: Box<dyn Storage>

Temporary storage for updates during commit.

Implementations

impl BasicAtomicFile

pub fn new(stg: Box<dyn Storage>, upd: Box<dyn Storage>) -> Box<Self>

stg is the main underlying storage, upd is temporary storage for updates during commit.

pub fn commit_phase(&mut self, size: u64, phase: u8)

Perform the specified phase ( 1 or 2 ) of a two-phase commit.

Trait Implementations

impl Storage for BasicAtomicFile

fn commit(&mut self, size: u64)

Finish write transaction, size is new size of underlying storage, time is the database time (#commits since server started).

fn size(&self) -> u64

Get the size of the underlying storage. Note : this is valid initially and after a commit but is not defined after write is called.

fn read(&self, start: u64, data: &mut [u8])

Read data from storage.

fn write_data(&mut self, start: u64, data: Data, off: usize, len: usize)

Write Data slice to storage.

fn write(&mut self, start: u64, data: &[u8])

Write byte slice to storage.

fn write_vec(&mut self, start: u64, data: Vec<u8>)

Write byte Vec to storage.

fn write_u64(&mut self, start: u64, value: u64)

Write u64 to storage.

fn read_u64(&self, start: u64) -> u64

Read u64 from storage.

fn clone(&self) -> Box<dyn Storage>

fn flush(&mut self)

Finish writing data to permanent storage.

fn complete(&self, _done: u64) -> (bool, u64)

Is flushing complete?