Struct timely::progress::broadcast::Progcaster

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

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

Methods

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

pub fn new<A: Allocate>(
    allocator: &mut A,
    path: &Vec<usize>,
    logging: Logger
) -> Progcaster<T>

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

pub fn send_and_recv(
    &mut self,
    messages: &mut ChangeBatch<(usize, usize, T)>,
    internal: &mut ChangeBatch<(usize, usize, T)>
)

Sends and receives progress updates, broadcasting the contents of messages and internal, and updating each with updates from other workers.