Struct mz_txn_wal::txn_write::TxnApply

pub struct TxnApply<T> {
    is_empty: bool,
    pub(crate) commit_ts: T,
}

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

Fields

is_empty: bool

commit_ts: T

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 + Sync, D: Debug + Semigroup + Ord + Codec64 + Send + Sync, O: Opaque + Debug + Codec64, C: TxnsCodec,

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

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

Tests for self and other values to be equal, and is used by ==.

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

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

impl<T> StructuralPartialEq for TxnApply<T>