Struct coord::coord::arrangement_state::Frontiers

pub struct Frontiers<T: Timestamp> {
    pub upper: MutableAntichain<T>,
    pub since: Rc<RefCell<MutableAntichain<T>>>,
    since_action: Rc<RefCell<dyn FnMut(Antichain<T>)>>,
    pub compaction_window_ms: Option<T>,
}

Fields

upper: MutableAntichain<T>

The most recent frontier for new data. All further changes will be in advance of this bound.

since: Rc<RefCell<MutableAntichain<T>>>

The compaction frontier. All peeks in advance of this frontier will be correct, but peeks not in advance of this frontier may not be.

since_action: Rc<RefCell<dyn FnMut(Antichain<T>)>>

The function to run on since changes. Passes the new since frontier.

compaction_window_ms: Option<T>

Compaction delay.

This timestamp drives the advancement of the since frontier as a function of the upper frontier, trailing it by exactly this much.

Implementations

impl<T: Timestamp + Copy> Frontiers<T>

pub fn new<I, F>(
    initial: I,
    compaction_window_ms: Option<T>,
    since_action: F
) -> (Self, AntichainToken<T>) where
    I: IntoIterator<Item = T>,
    F: FnMut(Antichain<T>) + 'static, 

Creates an empty index state from a function to run when the since changes. Returns the initial since handle.

pub fn since_handle<I>(&self, values: I) -> AntichainToken<T> where
    I: IntoIterator<Item = T>, 

Returns a wrapped MutableAntichain that propogates changes to since.

pub fn set_compaction_window_ms(&mut self, window_ms: Option<T>)

Sets the latency behind the collection frontier at which compaction occurs.