Struct mz_persist_txn::txn_write::TxnApply

pub struct TxnApply<T> { /* private fields */ }

A token representing the asynchronous “apply” work expected to be promptly performed by a txn committer.

Implementations

impl<T> TxnApply<T>

pub async fn apply<K, V, D, O, C>( self, handle: &mut TxnsHandle<K, V, T, D, O, C> ) -> Tidy

where K: Debug + Codec, V: Debug + Codec, T: Timestamp + Lattice + TotalOrder + StepForward + Codec64, D: Semigroup + Codec64 + Send + Sync, O: Opaque + Debug + Codec64, C: TxnsCodec,

Applies the txn, unblocking reads at timestamp it was committed at.

pub async fn apply_eager<K, V, D, O, C>( self, handle: &mut TxnsHandle<K, V, T, D, O, C> ) -> Tidy

where K: Debug + Codec, V: Debug + Codec, T: Timestamp + Lattice + TotalOrder + StepForward + Codec64, D: Semigroup + Codec64 + Send + Sync, O: Opaque + Debug + Codec64, C: TxnsCodec,

Self::apply but also advances the physical upper of each data shard past the commit timestamp.

pub fn is_empty(&self) -> bool

Returns whether the apply represents a txn with any non-tidy writes.

If this returns true, the apply is essentially a no-op and safe to discard.

Trait Implementations

impl<T: Debug> Debug for TxnApply<T>

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

Formats the value using the given formatter.

impl<T: PartialEq> PartialEq for TxnApply<T>

fn eq(&self, other: &TxnApply<T>) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<T> StructuralPartialEq for TxnApply<T>