Struct mz_txn_wal::txn_cache::DataTimes

pub(crate) struct DataTimes<T> {
    pub(crate) registered: VecDeque<DataRegistered<T>>,
    pub(crate) writes: VecDeque<T>,
}

Fields

registered: VecDeque<DataRegistered<T>>

The times at which the data shard was in the txns set.

Invariants:

• At least one registration (otherwise we filter this out of the cache).
• These are in increasing order.
• These are non-overlapping intervals.
• Everything in writes is in one of these intervals.

writes: VecDeque<T>

Invariant: These are in increasing order.

Implementations

impl<T: Timestamp + TotalOrder> DataTimes<T>

pub(crate) fn last_reg(&self) -> &DataRegistered<T>

fn first_reg(&self) -> &DataRegistered<T>

fn latest_physical_ts(&self) -> &T

Returns the latest known physical upper of a data shard.

pub(crate) fn validate(&self) -> Result<(), String>

Trait Implementations

impl<T: Debug> Debug for DataTimes<T>

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

Formats the value using the given formatter.

impl<T> Default for DataTimes<T>

fn default() -> Self

Returns the “default value” for a type.