Struct mz_compute_client::controller::instance::RefreshIntrospectionState

struct RefreshIntrospectionState<T> {
    refresh_schedule: RefreshSchedule,
    initial_as_of: Antichain<T>,
    next_refresh: Datum<'static>,
    last_completed_refresh: Datum<'static>,
}

Information needed to compute introspection updates for a REFRESH materialized view when the write frontier advances.

Fields

refresh_schedule: RefreshSchedule

initial_as_of: Antichain<T>

next_refresh: Datum<'static>

last_completed_refresh: Datum<'static>

Implementations

impl<T> RefreshIntrospectionState<T>

fn row_for_collection(&self, collection_id: GlobalId) -> Row

Return a Row reflecting the current refresh introspection state.

impl<T: ComputeControllerTimestamp> RefreshIntrospectionState<T>

fn new( refresh_schedule: RefreshSchedule, initial_as_of: Antichain<T>, upper: &Antichain<T>, ) -> Self

Construct a new RefreshIntrospectionState, and apply an initial frontier_update() at the upper.

fn frontier_update(&mut self, write_frontier: &Antichain<T>)

Should be called whenever the write frontier of the collection advances. It updates the state that should be recorded in introspection relations, but doesn’t send the updates yet.

Trait Implementations

impl<T: Debug> Debug for RefreshIntrospectionState<T>

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

Formats the value using the given formatter.