Struct tikv::server::debug::MvccChecker

[+] Show declaration

pub struct MvccChecker {
    lock_iter: RocksEngineIterator,
    default_iter: RocksEngineIterator,
    write_iter: RocksEngineIterator,
    scan_count: usize,
    lock_fix_count: usize,
    default_fix_count: usize,
    write_fix_count: usize,
    pub thread_index: usize,
}

Fields

lock_iter: RocksEngineIterator

default_iter: RocksEngineIterator

write_iter: RocksEngineIterator

scan_count: usize

lock_fix_count: usize

default_fix_count: usize

write_fix_count: usize

thread_index: usize

Implementations

impl MvccChecker[−]

fn new(db: Arc<DB>, start_key: &[u8], end_key: &[u8]) -> Result<Self>

fn min_key(
    key: Option<Vec<u8>>,
    iter: &RocksEngineIterator,
    f: fn(_: &[u8]) -> &[u8]
) -> Option<Vec<u8>>

pub fn check_mvcc(
    &mut self,
    wb: &mut RocksWriteBatch,
    limit: Option<usize>
) -> Result<()>

fn check_mvcc_key(&mut self, wb: &mut RocksWriteBatch, key: &[u8]) -> Result<()>

fn next_lock(&mut self, key: &[u8]) -> Result<Option<Lock>>

fn next_default(&mut self, key: &[u8]) -> Result<Option<TimeStamp>>

fn next_write(&mut self, key: &[u8]) -> Result<Option<(TimeStamp, Write)>>

fn delete(
    &mut self,
    wb: &mut RocksWriteBatch,
    cf: &str,
    key: &[u8],
    ts: Option<TimeStamp>
) -> Result<()>