Struct coord::coord::arrangement_state::Frontiers [−][src]
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
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,
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.
Returns a wrapped MutableAntichain that propogates changes to since
.
Sets the latency behind the collection frontier at which compaction occurs.
Auto Trait Implementations
impl<T> !RefUnwindSafe for Frontiers<T>
impl<T> !UnwindSafe for Frontiers<T>
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more