mz_cluster::types

Trait AsRunnableWorker

Source
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>, UnboundedSender<Self::Activatable>)>,
        persist_clients: Arc<PersistClientCache>,
        txns_ctx: TxnsContext,
        tracing_handle: Arc<TracingHandle>,
    );
}
Expand description

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§

Source

type Activatable: Activatable + Send

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

Required Methods§

Source

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

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

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§