Enum tikv::storage::txn::commands::Command

pub enum Command {
    Prewrite(Prewrite),
    PrewritePessimistic(PrewritePessimistic),
    AcquirePessimisticLock(AcquirePessimisticLock),
    Commit(Commit),
    Cleanup(Cleanup),
    Rollback(Rollback),
    PessimisticRollback(PessimisticRollback),
    TxnHeartBeat(TxnHeartBeat),
    CheckTxnStatus(CheckTxnStatus),
    CheckSecondaryLocks(CheckSecondaryLocks),
    ResolveLockReadPhase(ResolveLockReadPhase),
    ResolveLock(ResolveLock),
    ResolveLockLite(ResolveLockLite),
    Pause(Pause),
    MvccByKey(MvccByKey),
    MvccByStartTs(MvccByStartTs),
    RawCompareAndSwap(RawCompareAndSwap),
    RawAtomicStore(RawAtomicStore),
}

Store Transaction scheduler commands.

Learn more about our transaction system at Deep Dive TiKV: Distributed Transactions

These are typically scheduled and used through the Storage with functions like prewrite trait and are executed asynchronously.

Variants

Prewrite(Prewrite)

PrewritePessimistic(PrewritePessimistic)

AcquirePessimisticLock(AcquirePessimisticLock)

Commit(Commit)

Cleanup(Cleanup)

Rollback(Rollback)

PessimisticRollback(PessimisticRollback)

TxnHeartBeat(TxnHeartBeat)

CheckTxnStatus(CheckTxnStatus)

CheckSecondaryLocks(CheckSecondaryLocks)

ResolveLockReadPhase(ResolveLockReadPhase)

ResolveLock(ResolveLock)

ResolveLockLite(ResolveLockLite)

Pause(Pause)

MvccByKey(MvccByKey)

MvccByStartTs(MvccByStartTs)

RawCompareAndSwap(RawCompareAndSwap)

RawAtomicStore(RawAtomicStore)

Implementations

impl Command

fn command_ext(&self) -> &dyn CommandExt

fn command_ext_mut(&mut self) -> &mut dyn CommandExt

pub(super) fn process_read<S: Snapshot>(
    self,
    snapshot: S,
    statistics: &mut Statistics
) -> Result<ProcessResult>

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

pub fn readonly(&self) -> bool

pub fn incr_cmd_metric(&self)

pub fn priority(&self) -> CommandPri

pub fn need_flow_control(&self) -> bool

pub fn tag(&self) -> CommandKind

pub fn ts(&self) -> TimeStamp

pub fn write_bytes(&self) -> usize

pub fn gen_lock(&self) -> Lock

pub fn can_be_pipelined(&self) -> bool

pub fn ctx(&self) -> &Context

pub fn ctx_mut(&mut self) -> &mut Context

Trait Implementations

impl Debug for Command

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Display for Command

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: StorageCallbackType> From<Command> for TypedCommand<T>

fn from(cmd: Command) -> TypedCommand<T>

Performs the conversion.

impl<T> From<TypedCommand<T>> for Command

fn from(t: TypedCommand<T>) -> Command

Performs the conversion.