Struct test_backup::TestSuite

pub struct TestSuite {
    pub cluster: Cluster<ServerCluster>,
    pub endpoints: HashMap<u64, LazyWorker<Task>>,
    pub tikv_cli: TikvClient,
    pub context: Context,
    pub ts: TimeStamp,
    pub bg_worker: Worker,
    _env: Arc<Environment>,
}

Fields

cluster: Cluster<ServerCluster>

endpoints: HashMap<u64, LazyWorker<Task>>

tikv_cli: TikvClient

context: Context

ts: TimeStamp

bg_worker: Worker

_env: Arc<Environment>

Implementations

impl TestSuite

pub fn new(count: usize, sst_max_size: u64) -> TestSuite

pub fn alloc_ts(&mut self) -> TimeStamp

pub fn stop(self)

pub fn must_raw_put(&self, k: Vec<u8>, v: Vec<u8>, cf: String)

pub fn must_kv_prewrite(&self, muts: Vec<Mutation>, pk: Vec<u8>, ts: TimeStamp)

pub fn must_kv_commit(
    &self,
    keys: Vec<Vec<u8>>,
    start_ts: TimeStamp,
    commit_ts: TimeStamp
)

pub fn must_kv_put(&mut self, key_count: usize, versions: usize)

pub fn backup(
    &self,
    start_key: Vec<u8>,
    end_key: Vec<u8>,
    begin_ts: TimeStamp,
    backup_ts: TimeStamp,
    path: &Path
) -> UnboundedReceiver<BackupResponse>

pub fn backup_raw(
    &self,
    start_key: Vec<u8>,
    end_key: Vec<u8>,
    cf: String,
    path: &Path
) -> UnboundedReceiver<BackupResponse>

pub fn admin_checksum(
    &self,
    backup_ts: TimeStamp,
    start: String,
    end: String
) -> (u64, u64, u64)

pub fn gen_raw_kv(&self, key_idx: u64) -> (String, String)

pub fn raw_kv_checksum(
    &self,
    start: String,
    end: String,
    cf: CfName
) -> (u64, u64, u64)