Enum mz_persist_txn::txn_read::DataListenNext

pub enum DataListenNext<T> {
    ReadDataTo(T),
    EmitLogicalProgress(T),
    WaitForTxnsProgress,
}

The next action to take in a data shard Listen.

See crate::txn_cache::TxnsCacheState::data_listen_next.

Variants

ReadDataTo(T)

Read the data shard normally, until this timestamp is less_equal what has been read.

EmitLogicalProgress(T)

It is known that there are no writes between the progress given to the data_listen_next call and this timestamp. Advance the data shard listen progress to this (exclusive) frontier.

WaitForTxnsProgress

The data shard listen has caught up to what has been written to the txns shard. Wait for it to progress with update_gt and call data_listen_next again.

Trait Implementations

impl<T: Debug> Debug for DataListenNext<T>

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

Formats the value using the given formatter.

impl<T: PartialEq> PartialEq for DataListenNext<T>

fn eq(&self, other: &DataListenNext<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 DataListenNext<T>