Struct pancake_engine_ssi::opers::sicr::ScndIdxCreationJob

struct ScndIdxCreationJob<'job> {
    db: &'job DB,
    _si_cr_guard: MutexGuard<'job, ()>,
    sv_spec: Arc<SubValueSpec>,
    si_num: ScndIdxNum,
    pre_output_commit_ver: CommitVer,
    output_commit_ver: CommitVer,
    output_node: NonNullSendPtr<ListNode<CommittedUnit>>,
    job_dir: ScndIdxCreationJobDir,
    prim_entryset_file_paths: Vec<PathBuf>,
}

Fields

db: &'job DB

_si_cr_guard: MutexGuard<'job, ()>

sv_spec: Arc<SubValueSpec>

si_num: ScndIdxNum

pre_output_commit_ver: CommitVer

output_commit_ver: CommitVer

output_node: NonNullSendPtr<ListNode<CommittedUnit>>

job_dir: ScndIdxCreationJobDir

prim_entryset_file_paths: Vec<PathBuf>

Implementations

impl<'job> ScndIdxCreationJob<'job>

pub(super) fn create_unit(&mut self) -> Result<Option<PathBuf>>

fn derive_scnd_entries<'snap>( &'snap self ) -> Result<impl 'snap + Iterator<Item = Result<(SVPKShared, PVShared)>>>

fn create_all_intermediary_files<'a>( &self, scnd_entries: impl 'a + Iterator<Item = Result<(SVPKShared, PVShared)>> ) -> Result<Vec<PathBuf>>

fn create_one_intermediary_file( &self, memtable: &BTreeMap<SVPKShared, PVShared> ) -> Result<PathBuf>

fn merge_intermediary_files( &self, interm_file_paths: Vec<PathBuf> ) -> Result<Option<PathBuf>>

impl<'job> ScndIdxCreationJob<'job>

async fn new( db: &'job DB, sv_spec: &Arc<SubValueSpec> ) -> Result<Self, ScndIdxCreationJobErr>

async fn run(&mut self) -> Result<(), ScndIdxCreationJobErr>

async fn modify_lsm_state( &self, merged_file_path: Option<PathBuf> ) -> Result<()>

fn remove_intermediary_files(self) -> Result<()>