Struct timely::progress::broadcast::Progcaster

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

Manages broadcasting of progress updates to and receiving updates from workers.

Implementations

impl<T: Timestamp + Send> Progcaster<T>

pub fn new<A: AsWorker>( worker: &mut A, addr: Rc<[usize]>, logging: Option<Logger>, progress_logging: Option<ProgressLogger>, ) -> Progcaster<T>

Creates a new Progcaster using a channel from the supplied worker.

pub fn send(&mut self, changes: &mut ChangeBatch<(Location, T)>)

Sends pointstamp changes to all workers.

pub fn recv(&mut self, changes: &mut ChangeBatch<(Location, T)>)

Receives pointstamp changes from all workers.