Struct tikv::storage::txn::actions::prewrite::PrewriteMutation

struct PrewriteMutation<'a> {
    key: Key,
    value: Option<Value>,
    mutation_type: MutationType,
    secondary_keys: &'a Option<Vec<Vec<u8>>>,
    min_commit_ts: TimeStamp,
    lock_type: Option<LockType>,
    lock_ttl: u64,
    should_not_exist: bool,
    should_not_write: bool,
    txn_props: &'a TransactionProperties<'a>,
}

A single mutation to be prewritten.

Fields

key: Key

value: Option<Value>

mutation_type: MutationType

secondary_keys: &'a Option<Vec<Vec<u8>>>

min_commit_ts: TimeStamp

lock_type: Option<LockType>

lock_ttl: u64

should_not_exist: bool

should_not_write: bool

txn_props: &'a TransactionProperties<'a>

Implementations

impl<'a> PrewriteMutation<'a>

fn from_mutation(
    mutation: Mutation,
    secondary_keys: &'a Option<Vec<Vec<u8>>>,
    txn_props: &'a TransactionProperties<'a>
) -> Result<PrewriteMutation<'a>>

fn lock_info(&self, lock: Lock) -> Result<LockInfo>

fn check_lock(
    &mut self,
    lock: Lock,
    is_pessimistic_lock: bool
) -> Result<LockStatus>

Check whether the current key is locked at any timestamp.

fn check_for_newer_version<S: Snapshot>(
    &self,
    reader: &mut SnapshotReader<S>
) -> Result<Option<Write>>

fn write_lock(
    self,
    lock_status: LockStatus,
    txn: &mut MvccTxn
) -> Result<TimeStamp>

fn write_conflict_error(
    &self,
    write: &Write,
    commit_ts: TimeStamp
) -> Result<()>

fn skip_constraint_check(&self) -> bool

fn need_min_commit_ts(&self) -> bool

fn try_one_pc(&self) -> bool