Struct test_storage::AssertionStorage

[+] Show declaration

pub struct AssertionStorage<E: Engine> {
    pub store: SyncTestStorage<E>,
    pub ctx: Context,
}

Fields

store: SyncTestStorage<E>

ctx: Context

Implementations

impl AssertionStorage<SimulateEngine>[−]

pub fn new_raft_storage_with_store_count(
    count: usize,
    key: &str
) -> (Cluster<ServerCluster>, Self)

pub fn update_with_key_byte(
    &mut self,
    cluster: &mut Cluster<ServerCluster>,
    key: &[u8]
)

pub fn delete_ok_for_cluster(
    &mut self,
    cluster: &mut Cluster<ServerCluster>,
    key: &[u8],
    start_ts: impl Into<TimeStamp>,
    commit_ts: impl Into<TimeStamp>
)

fn get_from_custer(
    &mut self,
    cluster: &mut Cluster<ServerCluster>,
    key: &[u8],
    ts: impl Into<TimeStamp>
) -> Option<Value>

pub fn get_none_from_cluster(
    &mut self,
    cluster: &mut Cluster<ServerCluster>,
    key: &[u8],
    ts: impl Into<TimeStamp>
)

pub fn put_ok_for_cluster(
    &mut self,
    cluster: &mut Cluster<ServerCluster>,
    key: &[u8],
    value: &[u8],
    start_ts: impl Into<TimeStamp>,
    commit_ts: impl Into<TimeStamp>
)

fn two_pc_ok_for_cluster(
    &mut self,
    cluster: &mut Cluster<ServerCluster>,
    prewrite_mutations: Vec<Mutation>,
    key: &[u8],
    commit_keys: Vec<Key>,
    start_ts: impl Into<TimeStamp>,
    commit_ts: impl Into<TimeStamp>
)

pub fn gc_ok_for_cluster(
    &mut self,
    cluster: &mut Cluster<ServerCluster>,
    region_key: &[u8],
    safe_point: impl Into<TimeStamp>
)

pub fn test_txn_store_gc3_for_cluster(
    &mut self,
    cluster: &mut Cluster<ServerCluster>,
    key_prefix: u8
)

impl<E: Engine> AssertionStorage<E>[−]

pub fn get_none(&self, key: &[u8], ts: impl Into<TimeStamp>)

pub fn get_err(&self, key: &[u8], ts: impl Into<TimeStamp>)

pub fn get_ok(&self, key: &[u8], ts: impl Into<TimeStamp>, expect: &[u8])

pub fn batch_get_ok(
    &self,
    keys: &[&[u8]],
    ts: impl Into<TimeStamp>,
    expect: Vec<&[u8]>
)

pub fn batch_get_command_ok(&self, keys: &[&[u8]], ts: u64, expect: Vec<&[u8]>)

fn expect_not_leader_or_stale_command(&self, err: Error)

fn expect_invalid_tso_err<T>(
    &self,
    resp: Result<T, Error>,
    sts: impl Into<TimeStamp>,
    cmt_ts: impl Into<TimeStamp>
) where
    T: Debug, 

pub fn put_ok(
    &self,
    key: &[u8],
    value: &[u8],
    start_ts: impl Into<TimeStamp>,
    commit_ts: impl Into<TimeStamp>
)

pub fn delete_ok(
    &self,
    key: &[u8],
    start_ts: impl Into<TimeStamp>,
    commit_ts: impl Into<TimeStamp>
)

pub fn scan_ok(
    &self,
    start_key: &[u8],
    limit: usize,
    ts: impl Into<TimeStamp>,
    expect: Vec<Option<(&[u8], &[u8])>>
)

pub fn reverse_scan_ok(
    &self,
    start_key: &[u8],
    limit: usize,
    ts: impl Into<TimeStamp>,
    expect: Vec<Option<(&[u8], &[u8])>>
)

pub fn scan_key_only_ok(
    &self,
    start_key: &[u8],
    limit: usize,
    ts: impl Into<TimeStamp>,
    expect: Vec<Option<&[u8]>>
)

pub fn prewrite_ok(
    &self,
    mutations: Vec<Mutation>,
    primary: &[u8],
    start_ts: impl Into<TimeStamp>
)

pub fn prewrite_err(
    &self,
    mutations: Vec<Mutation>,
    primary: &[u8],
    start_ts: impl Into<TimeStamp>
)

pub fn prewrite_locked(
    &self,
    mutations: Vec<Mutation>,
    primary: &[u8],
    start_ts: impl Into<TimeStamp>,
    expect_locks: Vec<(&[u8], &[u8], TimeStamp)>
)

pub fn prewrite_conflict(
    &self,
    mutations: Vec<Mutation>,
    cur_primary: &[u8],
    cur_start_ts: impl Into<TimeStamp>,
    confl_key: &[u8],
    confl_ts: impl Into<TimeStamp>
)

pub fn commit_ok(
    &self,
    keys: Vec<&[u8]>,
    start_ts: impl Into<TimeStamp>,
    commit_ts: impl Into<TimeStamp>,
    actual_commit_ts: impl Into<TimeStamp>
)

pub fn commit_with_illegal_tso(
    &self,
    keys: Vec<&[u8]>,
    start_ts: impl Into<TimeStamp>,
    commit_ts: impl Into<TimeStamp>
)

pub fn cleanup_ok(
    &self,
    key: &[u8],
    start_ts: impl Into<TimeStamp>,
    current_ts: impl Into<TimeStamp>
)

pub fn cleanup_err(
    &self,
    key: &[u8],
    start_ts: impl Into<TimeStamp>,
    current_ts: impl Into<TimeStamp>
)

pub fn rollback_ok(&self, keys: Vec<&[u8]>, start_ts: impl Into<TimeStamp>)

pub fn rollback_err(&self, keys: Vec<&[u8]>, start_ts: impl Into<TimeStamp>)

pub fn scan_locks_ok(
    &self,
    max_ts: impl Into<TimeStamp>,
    start_key: &[u8],
    end_key: &[u8],
    limit: usize,
    expect: Vec<LockInfo>
)

pub fn resolve_lock_ok(
    &self,
    start_ts: impl Into<TimeStamp>,
    commit_ts: Option<impl Into<TimeStamp>>
)

pub fn resolve_lock_batch_ok(
    &self,
    start_ts_1: impl Into<TimeStamp>,
    commit_ts_1: impl Into<TimeStamp>,
    start_ts_2: impl Into<TimeStamp>,
    commit_ts_2: impl Into<TimeStamp>
)

pub fn resolve_lock_with_illegal_tso(
    &self,
    start_ts: impl Into<TimeStamp>,
    commit_ts: Option<impl Into<TimeStamp>>
)

pub fn gc_ok(&self, safe_point: impl Into<TimeStamp>)

pub fn raw_get_ok(&self, cf: String, key: Vec<u8>, value: Option<Vec<u8>>)

pub fn raw_put_ok(&self, cf: String, key: Vec<u8>, value: Vec<u8>)

pub fn raw_put_err(&self, cf: String, key: Vec<u8>, value: Vec<u8>)

pub fn raw_delete_ok(&self, cf: String, key: Vec<u8>)

pub fn raw_delete_err(&self, cf: String, key: Vec<u8>)

pub fn raw_scan_ok(
    &self,
    cf: String,
    start_key: Vec<u8>,
    limit: usize,
    expect: Vec<(&[u8], &[u8])>
)

pub fn test_txn_store_gc(&self, key: &str)

pub fn test_txn_store_gc3(&self, key_prefix: u8)

Trait Implementations

impl<E: Clone + Engine> Clone for AssertionStorage<E>[+]

[+] Show hidden undocumented items

fn clone(&self) -> AssertionStorage<E>[−]

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)[−]

Performs copy-assignment from source.

impl Default for AssertionStorage<RocksEngine>[+]

[+] Show hidden undocumented items

fn default() -> Self[−]

Returns the “default value” for a type.