Struct pagecache::logger::Log

pub struct Log { /* fields omitted */ }

A sequential store which allows users to create reservations placed at known log offsets, used for writing persistent data structures that need to know where to find persisted bits in the future.

Methods

impl Log

pub fn start(config: Config, snapshot: Snapshot) -> Result<Self>

Start the log, open or create the configured file, and optionally start the periodic buffer flush thread.

pub fn start_raw_log(config: Config) -> Result<Self>

Starts a log for use without a materializer.

pub fn flush(&self) -> Result<usize>

Flushes any pending IO buffers to disk to ensure durability. Returns the number of bytes written during this call.

pub fn iter_from(&self, lsn: Lsn) -> LogIter

Return an iterator over the log, starting with a specified offset.

pub fn read(&self, pid: PageId, lsn: Lsn, ptr: DiskPtr) -> Result<LogRead>

read a buffer from the disk

pub fn stable_offset(&self) -> Lsn

returns the current stable offset written to disk

pub fn make_stable(&self, lsn: Lsn) -> Result<usize>

blocks until the specified log sequence number has been made stable on disk. Returns the number of bytes written during this call.

pub fn reserve(
    &self,
    log_kind: LogKind,
    pid: PageId,
    raw_buf: &[u8]
) -> Result<Reservation>

Tries to claim a reservation for writing a buffer to a particular location in stable storge, which may either be completed or aborted later. Useful for maintaining linearizability across CAS operations that may need to persist part of their operation.

Trait Implementations

impl Drop for Log

fn drop(&mut self)

Executes the destructor for this type.

impl Send for Log

impl Debug for Log

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

Formats the value using the given formatter.