Enum tikv::storage::txn::commands::Command[−][src]

[−]
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[src][−]

fn command_ext(&self) -> &dyn CommandExt[src]

fn command_ext_mut(&mut self) -> &mut dyn CommandExt[src]

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

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

pub fn readonly(&self) -> bool[src]

pub fn incr_cmd_metric(&self)[src]

pub fn priority(&self) -> CommandPri[src]

pub fn need_flow_control(&self) -> bool[src]

pub fn tag(&self) -> CommandKind[src]

pub fn ts(&self) -> TimeStamp[src]

pub fn write_bytes(&self) -> usize[src]

pub fn gen_lock(&self) -> Lock[src]

pub fn can_be_pipelined(&self) -> bool[src]

pub fn ctx(&self) -> &Context[src]

pub fn ctx_mut(&mut self) -> &mut Context[src]

Trait Implementations

impl Debug for Command[src][+]

impl Display for Command[src][+]

impl<T: StorageCallbackType> From<Command> for TypedCommand<T>[src][+]

impl<T> From<TypedCommand<T>> for Command[src][+]

Auto Trait Implementations

impl RefUnwindSafe for Command

impl Send for Command

impl Sync for Command

impl Unpin for Command

impl UnwindSafe for Command

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized, [src][+]

impl<T> Borrow<T> for T where
    T: ?Sized, [src][+]

impl<T> BorrowMut<T> for T where
    T: ?Sized, [src][+]

impl<V, W> ConvertFrom<W> for V where
    W: ConvertTo<V>, [src][+]

impl<T> From<T> for T[src][+]

impl<T> Instrument for T[src][+]

impl<T, U> Into<U> for T where
    U: From<T>, [src][+]

impl<T> Pointable for T[src][+]

type Init = T

The type for initializers.

impl<T> Pointable for T[src][+]

type Init = T

The type for initializers.

impl<T> Same<T> for T[src]

type Output = T

Should always be Self

impl<T> Sealed<T> for T where
    T: ?Sized, [src]

impl<T> SendSyncUnwindSafe for T where
    T: Send + Sync + UnwindSafe + ?Sized, [src]

impl<T> ToString for T where
    T: Display + ?Sized, [src][+]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, [src][+]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, [src][+]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<V, T> VZip<V> for T where
    V: MultiLane<T>, [src][+]