Struct sst_importer::sst_importer::ImportDir

pub struct ImportDir {
    root_dir: PathBuf,
    temp_dir: PathBuf,
    clone_dir: PathBuf,
}

ImportDir is responsible for operating SST files and related path calculations.

The file being written is stored in $root/.temp/$file_name. After writing is completed, the file is moved to $root/$file_name. The file generated from the ingestion process will be placed in $root/.clone/$file_name.

TODO: Add size and rate limit.

Fields

root_dir: PathBuf

temp_dir: PathBuf

clone_dir: PathBuf

Implementations

impl ImportDir

const TEMP_DIR: &'static str

const CLONE_DIR: &'static str

fn new<P: AsRef<Path>>(root: P) -> Result<ImportDir>

fn join(&self, meta: &SstMeta) -> Result<ImportPath>

fn create(
    &self,
    meta: &SstMeta,
    key_manager: Option<Arc<DataKeyManager>>
) -> Result<ImportFile>

fn delete_file(
    &self,
    path: &Path,
    key_manager: Option<&DataKeyManager>
) -> Result<()>

fn delete(
    &self,
    meta: &SstMeta,
    manager: Option<&DataKeyManager>
) -> Result<ImportPath>

fn exist(&self, meta: &SstMeta) -> Result<bool>

fn ingest<E: KvEngine>(
    &self,
    meta: &SstMeta,
    engine: &E,
    key_manager: Option<Arc<DataKeyManager>>
) -> Result<SSTMetaInfo>

fn list_ssts(&self) -> Result<Vec<SstMeta>>