Trait tikv::storage::txn::commands::WriteCommand

pub trait WriteCommand<S: Snapshot, L: LockManager>: CommandExt {
    fn process_write(
        self, 
        snapshot: S, 
        context: WriteContext<'_, L>
    ) -> Result<WriteResult>;
}

Commands that need to modify the database during execution will implement this trait.

Required methods

fn process_write(
    self,
    snapshot: S,
    context: WriteContext<'_, L>
) -> Result<WriteResult>

Loading content...

Implementors

impl<S: Snapshot, L: LockManager> WriteCommand<S, L> for AcquirePessimisticLock

fn process_write(
    self,
    snapshot: S,
    context: WriteContext<'_, L>
) -> Result<WriteResult>

impl<S: Snapshot, L: LockManager> WriteCommand<S, L> for RawAtomicStore

fn process_write(self, _: S, _: WriteContext<'_, L>) -> Result<WriteResult>

impl<S: Snapshot, L: LockManager> WriteCommand<S, L> for CheckSecondaryLocks

fn process_write(
    self,
    snapshot: S,
    context: WriteContext<'_, L>
) -> Result<WriteResult>

impl<S: Snapshot, L: LockManager> WriteCommand<S, L> for CheckTxnStatus

fn process_write(
    self,
    snapshot: S,
    context: WriteContext<'_, L>
) -> Result<WriteResult>

checks whether a transaction has expired its primary lock’s TTL, rollback the transaction if expired, or update the transaction’s min_commit_ts according to the metadata in the primary lock. When transaction T1 meets T2’s lock, it may invoke this on T2’s primary key. In this situation, self.start_ts is T2’s start_ts, caller_start_ts is T1’s start_ts, and the current_ts is literally the timestamp when this function is invoked; it may not be accurate.

impl<S: Snapshot, L: LockManager> WriteCommand<S, L> for Cleanup

fn process_write(
    self,
    snapshot: S,
    context: WriteContext<'_, L>
) -> Result<WriteResult>

impl<S: Snapshot, L: LockManager> WriteCommand<S, L> for Commit

fn process_write(
    self,
    snapshot: S,
    context: WriteContext<'_, L>
) -> Result<WriteResult>

impl<S: Snapshot, L: LockManager> WriteCommand<S, L> for RawCompareAndSwap

fn process_write(
    self,
    snapshot: S,
    _: WriteContext<'_, L>
) -> Result<WriteResult>

impl<S: Snapshot, L: LockManager> WriteCommand<S, L> for Pause

fn process_write(
    self,
    _snapshot: S,
    _context: WriteContext<'_, L>
) -> Result<WriteResult>

impl<S: Snapshot, L: LockManager> WriteCommand<S, L> for PessimisticRollback

fn process_write(
    self,
    snapshot: S,
    context: WriteContext<'_, L>
) -> Result<WriteResult>

Delete any pessimistic lock with small for_update_ts belongs to this transaction.

impl<S: Snapshot, L: LockManager> WriteCommand<S, L> for Prewrite

fn process_write(
    self,
    snapshot: S,
    context: WriteContext<'_, L>
) -> Result<WriteResult>

impl<S: Snapshot, L: LockManager> WriteCommand<S, L> for PrewritePessimistic

fn process_write(
    self,
    snapshot: S,
    context: WriteContext<'_, L>
) -> Result<WriteResult>

impl<S: Snapshot, L: LockManager> WriteCommand<S, L> for ResolveLock

fn process_write(
    self,
    snapshot: S,
    context: WriteContext<'_, L>
) -> Result<WriteResult>

impl<S: Snapshot, L: LockManager> WriteCommand<S, L> for ResolveLockLite

fn process_write(
    self,
    snapshot: S,
    context: WriteContext<'_, L>
) -> Result<WriteResult>

impl<S: Snapshot, L: LockManager> WriteCommand<S, L> for Rollback

fn process_write(
    self,
    snapshot: S,
    context: WriteContext<'_, L>
) -> Result<WriteResult>

impl<S: Snapshot, L: LockManager> WriteCommand<S, L> for TxnHeartBeat

fn process_write(
    self,
    snapshot: S,
    context: WriteContext<'_, L>
) -> Result<WriteResult>

Loading content...