Struct timely::progress::reachability::Tracker

pub struct Tracker<T: Timestamp> { /* private fields */ }

An interactive tracker of propagated reachability information.

A Tracker tracks, for a fixed graph topology, the implications of pointstamp changes at various node input and output ports. These changes may alter the potential pointstamps that could arrive at downstream input ports.

Implementations

impl<T: Timestamp> Tracker<T>

pub fn update(&mut self, location: Location, time: T, value: i64)

Updates the count for a time at a location.

pub fn update_target(&mut self, target: Target, time: T, value: i64)

Updates the count for a time at a target (operator input, scope output).

pub fn update_source(&mut self, source: Source, time: T, value: i64)

Updates the count for a time at a source (operator output, scope input).

pub fn tracking_anything(&mut self) -> bool

Indicates if any pointstamps have positive count.

pub fn allocate_from( builder: Builder<T>, logger: Option<TrackerLogger>, ) -> (Self, Vec<Vec<Antichain<T::Summary>>>)

Allocate a new Tracker using the shape from summaries.

The result is a pair of tracker, and the summaries from each input port to each output port.

If the optional logger is provided, it will be used to log various tracker events.

pub fn propagate_all(&mut self)

Propagates all pending updates.

The method drains self.input_changes and circulates their implications until we cease deriving new implications.

pub fn pushed_output(&mut self) -> &mut [ChangeBatch<T>]

Implications of maintained capabilities projected to each output.

pub fn pushed(&mut self) -> &mut ChangeBatch<(Location, T)>

A mutable reference to the pushed results of changes.

pub fn node_state(&self, index: usize) -> &PerOperator<T>

Reveals per-operator frontier state.

pub fn is_global(&self, location: Location, time: &T) -> bool

Indicates if pointstamp is in the scope-wide frontier.

Such a pointstamp would, if removed from self.pointstamps, cause a change to self.implications, which is what we track for per operator input frontiers. If the above do not hold, then its removal either 1. shouldn’t be possible, or 2. will not affect the output of self.implications.

Trait Implementations

impl<T: Timestamp> Drop for Tracker<T>

fn drop(&mut self)

Executes the destructor for this type.