Trait mz_cluster::types::AsRunnableWorker

pub trait AsRunnableWorker<C, R> {
    type Activatable: Activatable + Send;

    // Required method
    fn build_and_run<A: Allocate + 'static>(
        config: Self,
        timely_worker: &mut TimelyWorker<A>,
        client_rx: Receiver<(Receiver<C>, UnboundedSender<R>, Sender<Self::Activatable>)>,
        persist_clients: Arc<PersistClientCache>,
        tracing_handle: Arc<TracingHandle>
    );
}

A trait for letting specific server implementations hook into handling of CreateTimely commands. Usually implemented by the config object that are specific to the implementation.

Required Associated Types

type Activatable: Activatable + Send

The Activatable type this server needs to be activated when being send new commands.

Required Methods

fn build_and_run<A: Allocate + 'static>( config: Self, timely_worker: &mut TimelyWorker<A>, client_rx: Receiver<(Receiver<C>, UnboundedSender<R>, Sender<Self::Activatable>)>, persist_clients: Arc<PersistClientCache>, tracing_handle: Arc<TracingHandle> )

Build and continuously run a worker. Called on each timely thread.

Object Safety

This trait is not object safe.

Implementors