Struct mz_compute::compute_state::ActiveComputeState

pub struct ActiveComputeState<'a, A: Allocate> {
    pub timely_worker: &'a mut TimelyWorker<A>,
    pub compute_state: &'a mut ComputeState,
    pub response_tx: &'a mut UnboundedSender<ComputeResponse>,
}

A wrapper around ComputeState with a live timely worker and response channel.

Fields

timely_worker: &'a mut TimelyWorker<A>

The underlying Timely worker.

compute_state: &'a mut ComputeState

The compute state itself.

response_tx: &'a mut UnboundedSender<ComputeResponse>

The channel over which frontier information is reported.

Implementations

impl<'a, A: Allocate> ActiveComputeState<'a, A>

pub fn handle_compute_command(&mut self, cmd: ComputeCommand)

Entrypoint for applying a compute command.

pub fn initialize_logging(&mut self, config: &LoggingConfig)

Initializes timely dataflow logging and publishes as a view.

pub fn shutdown_logging(&mut self)

Disables timely dataflow logging.

This does not unpublish views and is only useful to terminate logging streams to ensure that clusterd can terminate cleanly.

pub fn report_compute_frontiers(&mut self)

Send progress information to the coordinator.

pub fn report_dropped_collections(&mut self)

Report dropped collections to the controller.

pub fn process_peeks(&mut self)

Scan pending peeks and attempt to retire each.

pub fn process_subscribes(&mut self)

Scan the shared subscribe response buffer, and forward results along.