Function mz_cluster::server::serve

source · 
pub fn serve<Worker, C, R>(
    config: ClusterConfig,
    worker_config: Worker
) -> Result<(TimelyContainerRef<C, R, Worker::Activatable>, impl Fn() -> Box<ClusterClient<Partitioned<LocalClient<C, R, Worker::Activatable>, C, R>, Worker, C, R>>), Error>
where
    C: Send + 'static,
    R: Send + 'static,
    (C, R): Partitionable<C, R>,
    Worker: AsRunnableWorker<C, R> + Clone + Send + Sync + 'static,
Expand description

Initiates a timely dataflow computation, processing cluster commands.