Struct Mvcc 

pub struct Mvcc {
    pub pager: Pager,
    pub reader_tsns: Arc<ReaderTsnRegistry>,
    pub writer_lock: Mutex<()>,
    pub page_size: usize,
    pub max_node_size: usize,
    pub headers: Mutex<Vec<Page>>,
    pub header_page_buf: Mutex<Vec<u8>>,
    pub page_buf: Mutex<Vec<u8>>,
    pub verbose: bool,
    pub zero_fill_pages: bool,
    /* private fields */
}

Fields

pager: Pager

reader_tsns: Arc<ReaderTsnRegistry>

writer_lock: Mutex<()>

page_size: usize

max_node_size: usize

headers: Mutex<Vec<Page>>

header_page_buf: Mutex<Vec<u8>>

page_buf: Mutex<Vec<u8>>

verbose: bool

zero_fill_pages: bool

Implementations

impl Mvcc

pub fn new(verbose: bool, options: StorageOptions) -> Result<Mvcc, DcbError>

pub fn get_latest_header_page(&self) -> Result<Arc<Page>, DcbError>

pub fn read_page(&self, page_id: PageID) -> Result<Arc<Page>, DcbError>

pub fn fsync(&self) -> Result<(), DcbError>

pub fn reader(&self) -> Result<Reader, DcbError>

pub fn writer(&self) -> Result<Writer, DcbError>

pub fn write_pages<'a, I>(&self, pages: I) -> Result<usize, DcbError>

where I: IntoIterator<Item = &'a Page>,

Write one or more pages to disk using the shared preallocated page buffer. Returns the number of pages written.

pub fn commit(&self, writer: &mut Writer) -> Result<(), DcbError>