Trait tikv_ctl::DebugExecutor[−][src]

pub(crate) trait DebugExecutor {
    fn print_bad_regions(&self);

    fn remove_fail_stores(
        &self, 
        store_ids: Vec<u64>, 
        region_ids: Option<Vec<u64>>
    );

    fn recreate_region(
        &self, 
        sec_mgr: Arc<SecurityManager>, 
        pd_cfg: &PdConfig, 
        region_id: u64
    );

    fn check_region_consistency(&self, _: u64);

    fn check_local_mode(&self);

    fn get_all_meta_regions(&self) -> Vec<u64>;

    fn get_value_by_key(&self, cf: &str, key: Vec<u8>) -> Vec<u8>;

    fn get_region_size(
        &self, 
        region: u64, 
        cfs: Vec<&str>
    ) -> Vec<(String, usize)>;

    fn get_region_info(&self, region: u64) -> RegionInfo;

    fn get_raft_log(&self, region: u64, index: u64) -> Entry;

    fn get_mvcc_infos(
        &self, 
        from: Vec<u8>, 
        to: Vec<u8>, 
        limit: u64
    ) -> Pin<Box<dyn Stream<Item = Result<(Vec<u8>, MvccInfo), String>>>>;

    fn raw_scan_impl(
        &self, 
        from_key: &[u8], 
        end_key: &[u8], 
        limit: usize, 
        cf: &str
    );

    fn do_compaction(
        &self, 
        db: DBType, 
        cf: &str, 
        from: &[u8], 
        to: &[u8], 
        threads: u32, 
        bottommost: BottommostLevelCompaction
    );

    fn set_region_tombstone(&self, regions: Vec<Region>);

    fn set_region_tombstone_by_id(&self, regions: Vec<u64>);

    fn recover_regions(&self, regions: Vec<Region>, read_only: bool);

    fn recover_all(&self, threads: usize, read_only: bool);

    fn modify_tikv_config(&self, config_name: &str, config_value: &str);

    fn dump_metrics(&self, tags: Vec<&str>);

    fn dump_region_properties(&self, region_id: u64);

    fn dump_range_properties(&self, start: Vec<u8>, end: Vec<u8>);

    fn dump_store_info(&self);

    fn dump_cluster_info(&self);

    fn dump_value(&self, cf: &str, key: Vec<u8>) { ... }

    fn dump_region_size(&self, region: u64, cfs: Vec<&str>) -> usize { ... }

    fn dump_all_region_size(&self, cfs: Vec<&str>) { ... }

    fn dump_region_info(&self, region: u64, skip_tombstone: bool) { ... }

    fn dump_all_region_info(&self, skip_tombstone: bool) { ... }

    fn dump_raft_log(&self, region: u64, index: u64) { ... }

    fn dump_mvccs_infos(
        &self, 
        from: Vec<u8>, 
        to: Vec<u8>, 
        limit: u64, 
        cfs: Vec<&str>, 
        start_ts: Option<u64>, 
        commit_ts: Option<u64>
    ) { ... }

    fn raw_scan(&self, from_key: &[u8], to_key: &[u8], limit: usize, cf: &str) { ... }

    fn diff_region(
        &self, 
        region: u64, 
        to_host: Option<&str>, 
        to_data_dir: Option<&str>, 
        to_config: &TiKvConfig, 
        mgr: Arc<SecurityManager>
    ) { ... }

    fn compact(
        &self, 
        address: Option<&str>, 
        db: DBType, 
        cf: &str, 
        from: Option<Vec<u8>>, 
        to: Option<Vec<u8>>, 
        threads: u32, 
        bottommost: BottommostLevelCompaction
    ) { ... }

    fn compact_region(
        &self, 
        address: Option<&str>, 
        db: DBType, 
        cf: &str, 
        region_id: u64, 
        threads: u32, 
        bottommost: BottommostLevelCompaction
    ) { ... }

    fn set_region_tombstone_after_remove_peer(
        &self, 
        mgr: Arc<SecurityManager>, 
        cfg: &PdConfig, 
        region_ids: Vec<u64>
    ) { ... }

    fn set_region_tombstone_force(&self, region_ids: Vec<u64>) { ... }

    fn recover_regions_mvcc(
        &self, 
        mgr: Arc<SecurityManager>, 
        cfg: &PdConfig, 
        region_ids: Vec<u64>, 
        read_only: bool
    ) { ... }

    fn recover_mvcc_all(&self, threads: usize, read_only: bool) { ... }
}

Required methods

fn print_bad_regions(&self)[src]

fn remove_fail_stores(&self, store_ids: Vec<u64>, region_ids: Option<Vec<u64>>)[src]

Recover the cluster when given store_ids are failed.

fn recreate_region(
    &self,
    sec_mgr: Arc<SecurityManager>,
    pd_cfg: &PdConfig,
    region_id: u64
)[src]

Recreate the region with metadata from pd, but alloc new id for it.

fn check_region_consistency(&self, _: u64)[src]

fn check_local_mode(&self)[src]

fn get_all_meta_regions(&self) -> Vec<u64>[src]

fn get_value_by_key(&self, cf: &str, key: Vec<u8>) -> Vec<u8>[src]

fn get_region_size(&self, region: u64, cfs: Vec<&str>) -> Vec<(String, usize)>[src]

fn get_region_info(&self, region: u64) -> RegionInfo[src]

fn get_raft_log(&self, region: u64, index: u64) -> Entry[src]

fn get_mvcc_infos(
    &self,
    from: Vec<u8>,
    to: Vec<u8>,
    limit: u64
) -> Pin<Box<dyn Stream<Item = Result<(Vec<u8>, MvccInfo), String>>>>[src]

fn raw_scan_impl(&self, from_key: &[u8], end_key: &[u8], limit: usize, cf: &str)[src]

fn do_compaction(
    &self,
    db: DBType,
    cf: &str,
    from: &[u8],
    to: &[u8],
    threads: u32,
    bottommost: BottommostLevelCompaction
)[src]

fn set_region_tombstone(&self, regions: Vec<Region>)[src]

fn set_region_tombstone_by_id(&self, regions: Vec<u64>)[src]

fn recover_regions(&self, regions: Vec<Region>, read_only: bool)[src]

fn recover_all(&self, threads: usize, read_only: bool)[src]

fn modify_tikv_config(&self, config_name: &str, config_value: &str)[src]

fn dump_metrics(&self, tags: Vec<&str>)[src]

fn dump_region_properties(&self, region_id: u64)[src]

fn dump_range_properties(&self, start: Vec<u8>, end: Vec<u8>)[src]

fn dump_store_info(&self)[src]

fn dump_cluster_info(&self)[src]

Loading content...

Provided methods

fn dump_value(&self, cf: &str, key: Vec<u8>)[src]

fn dump_region_size(&self, region: u64, cfs: Vec<&str>) -> usize[src]

fn dump_all_region_size(&self, cfs: Vec<&str>)[src]

fn dump_region_info(&self, region: u64, skip_tombstone: bool)[src]

fn dump_all_region_info(&self, skip_tombstone: bool)[src]

fn dump_raft_log(&self, region: u64, index: u64)[src]

fn dump_mvccs_infos(
    &self,
    from: Vec<u8>,
    to: Vec<u8>,
    limit: u64,
    cfs: Vec<&str>,
    start_ts: Option<u64>,
    commit_ts: Option<u64>
)[src]

Dump mvcc infos for a given key range. The given from and to must be raw key with z prefix. Both to and limit are empty value means what we want is point query instead of range scan.

fn raw_scan(&self, from_key: &[u8], to_key: &[u8], limit: usize, cf: &str)[src]

fn diff_region(
    &self,
    region: u64,
    to_host: Option<&str>,
    to_data_dir: Option<&str>,
    to_config: &TiKvConfig,
    mgr: Arc<SecurityManager>
)[src]

fn compact(
    &self,
    address: Option<&str>,
    db: DBType,
    cf: &str,
    from: Option<Vec<u8>>,
    to: Option<Vec<u8>>,
    threads: u32,
    bottommost: BottommostLevelCompaction
)[src]

fn compact_region(
    &self,
    address: Option<&str>,
    db: DBType,
    cf: &str,
    region_id: u64,
    threads: u32,
    bottommost: BottommostLevelCompaction
)[src]

fn set_region_tombstone_after_remove_peer(
    &self,
    mgr: Arc<SecurityManager>,
    cfg: &PdConfig,
    region_ids: Vec<u64>
)[src]

fn set_region_tombstone_force(&self, region_ids: Vec<u64>)[src]

fn recover_regions_mvcc(
    &self,
    mgr: Arc<SecurityManager>,
    cfg: &PdConfig,
    region_ids: Vec<u64>,
    read_only: bool
)[src]

fn recover_mvcc_all(&self, threads: usize, read_only: bool)[src]

Loading content...

Implementations on Foreign Types

impl DebugExecutor for DebugClient[src]

impl<ER: RaftEngine> DebugExecutor for Debugger<ER>[src]

Loading content...

Implementors

Loading content...