Struct tikv::server::debug::Debugger [−][src]
Fields
engines: Engines<RocksEngine, ER>cfg_controller: ConfigControllerImplementations
impl<ER: RaftEngine> Debugger<ER>[src]
pub fn new(
engines: Engines<RocksEngine, ER>,
cfg_controller: ConfigController
) -> Debugger<ER>[src]
engines: Engines<RocksEngine, ER>,
cfg_controller: ConfigController
) -> Debugger<ER>
pub fn get_engine(&self) -> &Engines<RocksEngine, ER>[src]
pub fn get_all_meta_regions(&self) -> Result<Vec<u64>>[src]
Get all regions holding region meta data from raft CF in KV storage.
fn get_db_from_type(&self, db: DBType) -> Result<&Arc<DB>>[src]
pub fn get(&self, db: DBType, cf: &str, key: &[u8]) -> Result<Vec<u8>>[src]
pub fn raft_log(&self, region_id: u64, log_index: u64) -> Result<Entry>[src]
pub fn region_info(&self, region_id: u64) -> Result<RegionInfo>[src]
pub fn region_size<T: AsRef<str>>(
&self,
region_id: u64,
cfs: Vec<T>
) -> Result<Vec<(T, usize)>>[src]
&self,
region_id: u64,
cfs: Vec<T>
) -> Result<Vec<(T, usize)>>
pub fn scan_mvcc(
&self,
start: &[u8],
end: &[u8],
limit: u64
) -> Result<MvccInfoIterator<RocksEngineIterator>>[src]
&self,
start: &[u8],
end: &[u8],
limit: u64
) -> Result<MvccInfoIterator<RocksEngineIterator>>
Scan MVCC Infos for given range [start, end).
pub fn raw_scan(
&self,
start: &[u8],
end: &[u8],
limit: usize,
cf: &str
) -> Result<Vec<(Vec<u8>, Vec<u8>)>>[src]
&self,
start: &[u8],
end: &[u8],
limit: usize,
cf: &str
) -> Result<Vec<(Vec<u8>, Vec<u8>)>>
Scan raw keys for given range [start, end) in given cf.
pub fn compact(
&self,
db: DBType,
cf: &str,
start: &[u8],
end: &[u8],
threads: u32,
bottommost: BottommostLevelCompaction
) -> Result<()>[src]
&self,
db: DBType,
cf: &str,
start: &[u8],
end: &[u8],
threads: u32,
bottommost: BottommostLevelCompaction
) -> Result<()>
Compact the cf[start..end) in the db.
pub fn set_region_tombstone(
&self,
regions: Vec<Region>
) -> Result<Vec<(u64, Error)>>[src]
&self,
regions: Vec<Region>
) -> Result<Vec<(u64, Error)>>
Set regions to tombstone by manual, and apply other status(such as
peers, version, and key range) from region which comes from PD normally.
pub fn set_region_tombstone_by_id(
&self,
regions: Vec<u64>
) -> Result<Vec<(u64, Error)>>[src]
&self,
regions: Vec<u64>
) -> Result<Vec<(u64, Error)>>
pub fn recover_regions(
&self,
regions: Vec<Region>,
read_only: bool
) -> Result<Vec<(u64, Error)>>[src]
&self,
regions: Vec<Region>,
read_only: bool
) -> Result<Vec<(u64, Error)>>
pub fn recover_all(&self, threads: usize, read_only: bool) -> Result<()>[src]
pub fn bad_regions(&self) -> Result<Vec<(u64, Error)>>[src]
pub fn remove_failed_stores(
&self,
store_ids: Vec<u64>,
region_ids: Option<Vec<u64>>
) -> Result<()>[src]
&self,
store_ids: Vec<u64>,
region_ids: Option<Vec<u64>>
) -> Result<()>
pub fn recreate_region(&self, region: Region) -> Result<()>[src]
pub fn get_store_id(&self) -> Result<u64>[src]
pub fn get_cluster_id(&self) -> Result<u64>[src]
pub fn modify_tikv_config(
&self,
config_name: &str,
config_value: &str
) -> Result<()>[src]
&self,
config_name: &str,
config_value: &str
) -> Result<()>
fn get_region_state(&self, region_id: u64) -> Result<RegionLocalState>[src]
pub fn get_region_properties(
&self,
region_id: u64
) -> Result<Vec<(String, String)>>[src]
&self,
region_id: u64
) -> Result<Vec<(String, String)>>
pub fn get_range_properties(
&self,
start: &[u8],
end: &[u8]
) -> Result<Vec<(String, String)>>[src]
&self,
start: &[u8],
end: &[u8]
) -> Result<Vec<(String, String)>>
Trait Implementations
impl<ER: Clone + RaftEngine> Clone for Debugger<ER>[src]
Auto Trait Implementations
impl<ER> RefUnwindSafe for Debugger<ER> where
ER: RefUnwindSafe,
ER: RefUnwindSafe,
impl<ER> Send for Debugger<ER>
impl<ER> Sync for Debugger<ER>
impl<ER> Unpin for Debugger<ER> where
ER: Unpin,
ER: Unpin,
impl<ER> UnwindSafe for Debugger<ER> where
ER: UnwindSafe,
ER: UnwindSafe,
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized, [src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T[src]
impl<V, W> ConvertFrom<W> for V where
W: ConvertTo<V>, [src]
W: ConvertTo<V>,
pub fn convert_from(ctx: &mut EvalContext, from: W) -> Result<V, Error>[src]
impl<T> From<T> for T[src]
impl<T> Instrument for T[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>[src]
pub fn in_current_span(self) -> Instrumented<Self>[src]
impl<T, U> Into<U> for T where
U: From<T>, [src]
U: From<T>,
impl<T> Pointable for T[src]
pub const ALIGN: usize[src]
type Init = T
The type for initializers.
pub unsafe fn init(init: <T as Pointable>::Init) -> usize[src]
pub unsafe fn deref<'a>(ptr: usize) -> &'a T[src]
pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T[src]
pub unsafe fn drop(ptr: usize)[src]
impl<T> Pointable for T[src]
pub const ALIGN: usize[src]
type Init = T
The type for initializers.
pub unsafe fn init(init: <T as Pointable>::Init) -> usize[src]
pub unsafe fn deref<'a>(ptr: usize) -> &'a T[src]
pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T[src]
pub unsafe fn drop(ptr: usize)[src]
impl<T> Same<T> for T[src]
type Output = T
Should always be Self
impl<T> Sealed<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> SendSyncUnwindSafe for T where
T: Send + Sync + UnwindSafe + ?Sized, [src]
T: Send + Sync + UnwindSafe + ?Sized,
impl<T> ToOwned for T where
T: Clone, [src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T[src]
pub fn clone_into(&self, target: &mut T)[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>, [src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>, [src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>, [src]
V: MultiLane<T>,