Struct declarative_dataflow::sources::SourcingContext

pub struct SourcingContext<T: Timestamp> {
    pub t0: Instant,
    pub domain_probe: ProbeHandle<T>,
    pub scheduler: Weak<RefCell<Scheduler>>,
    pub timely_events: Rc<EventLink<Duration, (Duration, usize, TimelyEvent)>>,
    pub differential_events: Rc<EventLink<Duration, (Duration, usize, DifferentialEvent)>>,
}

A struct encapsulating any state required to create sources.

Fields

t0: Instant

The logical start of the computation, used by sources to compute their relative progress.

domain_probe: ProbeHandle<T>

A handle to the timely probe of the domain this source is created in.

scheduler: Weak<RefCell<Scheduler>>

A weak handle to a scheduler, used by sources to defer their next activation when polling.

timely_events: Rc<EventLink<Duration, (Duration, usize, TimelyEvent)>>

A weak handle to a Timely event link.

differential_events: Rc<EventLink<Duration, (Duration, usize, DifferentialEvent)>>

A weak handle to Differential event link.