Struct tikv::import::SSTImporter

pub struct SSTImporter {
    dir: ImportDir,
    key_manager: Option<Arc<DataKeyManager>>,
    switcher: ImportModeSwitcher,
}

SSTImporter manages SST files that are waiting for ingesting.

Fields

dir: ImportDir

key_manager: Option<Arc<DataKeyManager>>

switcher: ImportModeSwitcher

Implementations

impl SSTImporter

pub fn new<P>(
    cfg: &Config,
    root: P,
    key_manager: Option<Arc<DataKeyManager>>
) -> Result<SSTImporter, Error> where
    P: AsRef<Path>, 

pub fn start_switch_mode_check<E>(&self, executor: &ThreadPool, db: E) where
    E: KvEngine, 

pub fn get_path(&self, meta: &SstMeta) -> PathBuf

pub fn create(&self, meta: &SstMeta) -> Result<ImportFile, Error>

pub fn delete(&self, meta: &SstMeta) -> Result<(), Error>

pub fn ingest<E>(
    &self,
    meta: &SstMeta,
    engine: &E
) -> Result<SSTMetaInfo, Error> where
    E: KvEngine, 

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

pub fn download<E>(
    &self,
    meta: &SstMeta,
    backend: &StorageBackend,
    name: &str,
    rewrite_rule: &RewriteRule,
    speed_limiter: Limiter<CoarseClock>,
    sst_writer: <E as SstExt>::SstWriter
) -> Result<Option<Range>, Error> where
    E: KvEngine, 

pub fn enter_normal_mode<E>(
    &self,
    db: E,
    mf: fn(&str, &str, f64)
) -> Result<bool, Error> where
    E: KvEngine, 

pub fn enter_import_mode<E>(
    &self,
    db: E,
    mf: fn(&str, &str, f64)
) -> Result<bool, Error> where
    E: KvEngine, 

pub fn get_mode(&self) -> SwitchMode

pub fn list_ssts(&self) -> Result<Vec<SstMeta, Global>, Error>

pub fn new_writer<E>(
    &self,
    db: &E,
    meta: SstMeta
) -> Result<SSTWriter<E>, Error> where
    E: KvEngine,