Struct pancake_engine_ssi::db::DB

pub struct DB {
    _lock_dir: File,
    db_state: RwLock<DbState>,
    lsm_dir: LsmDir,
    lsm_state: Mutex<LsmState>,
    si_cr_dir: ScndIdxCreationsDir,
    si_cr_mutex: Mutex<()>,
    fc_able_commit_vers_tx: Sender<CommitVer>,
    min_held_list_ver_tx: Sender<ListVer>,
    is_terminating_tx: Sender<()>,
}

Fields

_lock_dir: File

db_state: RwLock<DbState>

lsm_dir: LsmDir

lsm_state: Mutex<LsmState>

si_cr_dir: ScndIdxCreationsDir

si_cr_mutex: Mutex<()>

fc_able_commit_vers_tx: Sender<CommitVer>

min_held_list_ver_tx: Sender<ListVer>

is_terminating_tx: Sender<()>

Implementations

impl DB

pub(crate) fn _lock_dir(&self) -> &File

pub(crate) fn set__lock_dir(&mut self, value: File) -> &mut Self

pub(crate) fn db_state(&self) -> &RwLock<DbState>

pub(crate) fn set_db_state(&mut self, value: RwLock<DbState>) -> &mut Self

pub(crate) fn lsm_dir(&self) -> &LsmDir

pub(crate) fn set_lsm_dir(&mut self, value: LsmDir) -> &mut Self

pub(crate) fn lsm_state(&self) -> &Mutex<LsmState>

pub(crate) fn set_lsm_state(&mut self, value: Mutex<LsmState>) -> &mut Self

pub(crate) fn si_cr_dir(&self) -> &ScndIdxCreationsDir

pub(crate) fn set_si_cr_dir(&mut self, value: ScndIdxCreationsDir) -> &mut Self

pub(crate) fn si_cr_mutex(&self) -> &Mutex<()>

pub(crate) fn set_si_cr_mutex(&mut self, value: Mutex<()>) -> &mut Self

pub(crate) fn fc_able_commit_vers_tx(&self) -> &Sender<CommitVer>

pub(crate) fn set_fc_able_commit_vers_tx( &mut self, value: Sender<CommitVer> ) -> &mut Self

pub(crate) fn min_held_list_ver_tx(&self) -> &Sender<ListVer>

pub(crate) fn set_min_held_list_ver_tx( &mut self, value: Sender<ListVer> ) -> &mut Self

pub(crate) fn is_terminating_tx(&self) -> &Sender<()>

pub(crate) fn set_is_terminating_tx(&mut self, value: Sender<()>) -> &mut Self

impl DB

pub fn load_or_new<P: AsRef<Path>>( db_dir_path: P ) -> Result<(Arc<Self>, FlushingAndCompactionWorker)>

pub fn notify_min_held_list_ver(&self, mhlv: ListVer)

pub async fn terminate(&self)

impl DB

pub async fn create_scnd_idx( &self, sv_spec: &Arc<SubValueSpec> ) -> Result<(), ScndIdxCreationJobErr>

impl DB

pub async fn delete_scnd_idx( &self, sv_spec: &SubValueSpec ) -> Result<(), ScndIdxDeletionJobErr>