Struct mz_adapter::coord::timeline::TimestampOracle

struct TimestampOracle<T> {
    state: TimestampOracleState<T>,
    next: Box<dyn Fn() -> T>,
}

A type that provides write and read timestamps, reads observe exactly their preceding writes..

Specifically, all read timestamps will be greater or equal to all previously reported completed write timestamps, and strictly less than all subsequently emitted write timestamps.

Fields

state: TimestampOracleState<T>

next: Box<dyn Fn() -> T>

Implementations

impl<T: TimestampManipulation> TimestampOracle<T>

pub fn new<F>(initially: T, next: F) -> Selfwhere F: Fn() -> T + 'static,

Create a new timeline, starting at the indicated time. next generates new timestamps when invoked. The timestamps have no requirements, and can retreat from previous invocations.

fn write_ts(&mut self) -> WriteTimestamp<T>

Acquire a new timestamp for writing.

This timestamp will be strictly greater than all prior values of self.read_ts() and self.write_ts().

fn peek_write_ts(&self) -> T

Peek the current write timestamp.

fn read_ts(&self) -> T

Acquire a new timestamp for reading.

This timestamp will be greater or equal to all prior values of self.apply_write(write_ts), and strictly less than all subsequent values of self.write_ts().

fn apply_write(&mut self, write_ts: T)

Mark a write at write_ts completed.

All subsequent values of self.read_ts() will be greater or equal to write_ts.