Struct tikv::storage::txn::commands::pessimistic_rollback::PessimisticRollback [−][src]
Rollback pessimistic locks identified by start_ts
and for_update_ts
.
This can roll back an AcquirePessimisticLock
command.
Fields
ctx: Context
keys: Vec<Key>
The keys to be rolled back.
start_ts: TimeStamp
The transaction timestamp.
for_update_ts: TimeStamp
Implementations
impl PessimisticRollback
[src]
pub fn new(
keys: Vec<Key>,
start_ts: TimeStamp,
for_update_ts: TimeStamp,
ctx: Context
) -> TypedCommand<Vec<StorageResult<()>>>
[src]
keys: Vec<Key>,
start_ts: TimeStamp,
for_update_ts: TimeStamp,
ctx: Context
) -> TypedCommand<Vec<StorageResult<()>>>
Return a TypedCommand
that encapsulates the result of executing this command.
Trait Implementations
impl CommandExt for PessimisticRollback
[src]
fn get_ctx(&self) -> &Context
[src]
fn get_ctx_mut(&mut self) -> &mut Context
[src]
fn tag(&self) -> CommandKind
[src]
fn incr_cmd_metric(&self)
[src]
fn ts(&self) -> TimeStamp
[src]
fn write_bytes(&self) -> usize
[src]
fn gen_lock(&self) -> Lock
[src]
fn readonly(&self) -> bool
[src]
fn is_sys_cmd(&self) -> bool
[src]
fn can_be_pipelined(&self) -> bool
[src]
impl Debug for PessimisticRollback
[src]
impl Display for PessimisticRollback
[src]
impl<S: Snapshot, L: LockManager> WriteCommand<S, L> for PessimisticRollback
[src]
fn process_write(
self,
snapshot: S,
context: WriteContext<'_, L>
) -> Result<WriteResult>
[src]
self,
snapshot: S,
context: WriteContext<'_, L>
) -> Result<WriteResult>
Delete any pessimistic lock with small for_update_ts belongs to this transaction.
Auto Trait Implementations
impl RefUnwindSafe for PessimisticRollback
impl Send for PessimisticRollback
impl Sync for PessimisticRollback
impl Unpin for PessimisticRollback
impl UnwindSafe for PessimisticRollback
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<V, W> ConvertFrom<W> for V where
W: ConvertTo<V>,
[src]
W: ConvertTo<V>,
pub fn convert_from(ctx: &mut EvalContext, from: W) -> Result<V, Error>
[src]
impl<T> From<T> for T
[src]
impl<T> Instrument for T
[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> Pointable for T
[src]
pub const ALIGN: usize
[src]
type Init = T
The type for initializers.
pub unsafe fn init(init: <T as Pointable>::Init) -> usize
[src]
pub unsafe fn deref<'a>(ptr: usize) -> &'a T
[src]
pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T
[src]
pub unsafe fn drop(ptr: usize)
[src]
impl<T> Pointable for T
[src]
pub const ALIGN: usize
[src]
type Init = T
The type for initializers.
pub unsafe fn init(init: <T as Pointable>::Init) -> usize
[src]
pub unsafe fn deref<'a>(ptr: usize) -> &'a T
[src]
pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T
[src]
pub unsafe fn drop(ptr: usize)
[src]
impl<T> Same<T> for T
[src]
type Output = T
Should always be Self
impl<T> Sealed<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> SendSyncUnwindSafe for T where
T: Send + Sync + UnwindSafe + ?Sized,
[src]
T: Send + Sync + UnwindSafe + ?Sized,
impl<T> ToString for T where
T: Display + ?Sized,
[src]
T: Display + ?Sized,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
[src]
V: MultiLane<T>,