Enum mz_adapter::coord::timestamp_selection::TimestampContext

pub enum TimestampContext<T> {
    TimelineTimestamp {
        timeline: Timeline,
        chosen_ts: T,
        oracle_ts: Option<T>,
    },
    NoTimestamp,
}

The timeline and timestamp context of a read.

Variants

TimelineTimestamp

Read is executed in a specific timeline with a specific timestamp.

Fields

timeline: Timeline

chosen_ts: T

The timestamp that was chosen for a read. This can differ from the oracle_ts when collections are not readable at the (linearized) timestamp for the oracle. In those cases (when the chosen timestamp is further ahead than the oracle timestamp) we have to delay returning peek results until the timestamp oracle is also sufficiently advanced.

oracle_ts: Option<T>

The timestamp that would have been chosen for the read by the (linearized) timestamp oracle). In most cases this will be picked as the chosen_ts.

NoTimestamp

Read is execute without a timeline or timestamp.

Implementations

impl<T: TimestampManipulation> TimestampContext<T>

pub fn from_timeline_context( chosen_ts: T, oracle_ts: Option<T>, transaction_timeline: Option<Timeline>, timeline_context: &TimelineContext, ) -> TimestampContext<T>

Creates a TimestampContext from a timestamp and TimelineContext.

pub fn timeline(&self) -> Option<&Timeline>

The timeline belonging to this context, if one exists.

pub fn timestamp(&self) -> Option<&T>

The timestamp belonging to this context, if one exists.

pub fn timeline_timestamp(&self) -> Option<(&Timeline, &T)>

The timeline and timestamp belonging to this context, if one exists.

pub fn timestamp_or_default(&self) -> T

The timestamp belonging to this context, or a sensible default if one does not exists.

pub fn contains_timestamp(&self) -> bool

Whether or not the context contains a timestamp.

pub fn antichain(&self) -> Antichain<T>

Converts this TimestampContext to an Antichain.

Trait Implementations

impl<T: Clone> Clone for TimestampContext<T>

fn clone(&self) -> TimestampContext<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for TimestampContext<T>

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

Formats the value using the given formatter.

impl<'de, T> Deserialize<'de> for TimestampContext<T>

where T: Deserialize<'de>,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<T: PartialEq> PartialEq for TimestampContext<T>

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

where T: Serialize,

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<T> StructuralPartialEq for TimestampContext<T>