Struct Fs 

pub struct Fs { /* private fields */ }

A commitlog repository Repo which stores commits in ordinary files on disk.

Implementations

impl Fs

pub fn new(root: CommitLogDir) -> Result<Self>

Create a commitlog repository which stores segments in the directory root.

root must name an extant, accessible, writeable directory.

pub fn segment_path(&self, offset: u64) -> SegmentFile

Get the filename for a segment starting with offset within this repository.

pub fn size_on_disk(&self) -> Result<u64>

Determine the size on disk as the sum of the sizes of all segments.

Note that the actively written-to segment (if any) is included.

Trait Implementations

impl Clone for Fs

fn clone(&self) -> Fs

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Fs

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

Formats the value using the given formatter.

impl Repo for Fs

type SegmentWriter = File

The type of log segments managed by this repo, which must behave like a file.

type SegmentReader = CompressReader

fn create_segment(&self, offset: u64) -> Result<Self::SegmentWriter>

Create a new segment with the minimum transaction offset offset.

fn open_segment_writer(&self, offset: u64) -> Result<Self::SegmentWriter>

Open an existing segment at the minimum transaction offset offset.

fn open_segment_reader(&self, offset: u64) -> Result<Self::SegmentReader>

Open an existing segment at the minimum transaction offset offset.

fn remove_segment(&self, offset: u64) -> Result<()>

Remove the segment at the minimum transaction offset offset.

fn compress_segment(&self, offset: u64) -> Result<()>

Compress a segment in storage, marking it as immutable.

fn existing_offsets(&self) -> Result<Vec<u64>>

Traverse all segments in this repository and return list of their offsets, sorted in ascending order.

fn create_offset_index( &self, offset: TxOffset, cap: u64, ) -> Result<TxOffsetIndexMut>

Create TxOffsetIndexMut for the given offset or open it if already exist. The cap parameter is the maximum number of entries in the index.

fn remove_offset_index(&self, offset: TxOffset) -> Result<()>

Remove TxOffsetIndexMut named with offset.

fn get_offset_index(&self, offset: TxOffset) -> Result<TxOffsetIndex>

Get TxOffsetIndex for the given offset.