Struct timely::progress::reachability::PortInformation[−][src]

pub struct PortInformation<T: Timestamp> {
    pub pointstamps: MutableAntichain<T>,
    pub implications: MutableAntichain<T>,
    pub output_summaries: Vec<Antichain<T::Summary>>,
}

Per-port progress-tracking information.

Fields

pointstamps: MutableAntichain<T>

Current counts of active pointstamps.

implications: MutableAntichain<T>

Current implications of active pointstamps across the dataflow.

output_summaries: Vec<Antichain<T::Summary>>

Path summaries to each of the scope outputs.

Implementations

impl<T: Timestamp> PortInformation<T>[src]

pub fn new() -> Self[src]

Creates empty port information.

pub fn is_global(&self, time: &T) -> bool[src]

True if updates at this pointstamp uniquely block progress.

This method returns true if the currently maintained pointstamp counts are such that zeroing out outstanding updates at this pointstamp would change the frontiers at this operator. When the method returns false it means that, temporarily at least, there are outstanding pointstamp updates that are strictly less than this pointstamp.

Trait Implementations

impl<T: Clone + Timestamp> Clone for PortInformation<T> where
    T::Summary: Clone, [src]

Auto Trait Implementations

impl<T> RefUnwindSafe for PortInformation<T> where
    T: RefUnwindSafe,
    <T as Timestamp>::Summary: RefUnwindSafe, 

impl<T> Send for PortInformation<T> where
    <T as Timestamp>::Summary: Send, 

impl<T> Sync for PortInformation<T> where
    <T as Timestamp>::Summary: Sync, 

impl<T> Unpin for PortInformation<T> where
    T: Unpin,
    <T as Timestamp>::Summary: Unpin, 

impl<T> UnwindSafe for PortInformation<T> where
    T: UnwindSafe,
    <T as Timestamp>::Summary: UnwindSafe, 

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized, [src]

impl<T> Borrow<T> for T where
    T: ?Sized, [src]

impl<T> BorrowMut<T> for T where
    T: ?Sized, [src]

impl<T> Data for T where
    T: 'static + Clone, [src]

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, [src]

impl<T> ToOwned for T where
    T: Clone, [src]

type Owned = T

The resulting type after obtaining ownership.

impl<T, U> TryFrom<U> for T where
    U: Into<T>, [src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, [src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.