Trait AsRunnableWorker

pub trait AsRunnableWorker<C, R> {
    // Required method
    fn build_and_run<A: Allocate + 'static>(
        config: Self,
        timely_worker: &mut TimelyWorker<A>,
        client_rx: Receiver<(Receiver<C>, UnboundedSender<R>, UnboundedSender<LocalActivator>)>,
        persist_clients: Arc<PersistClientCache>,
        txns_ctx: TxnsContext,
        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 Methods

fn build_and_run<A: Allocate + 'static>( config: Self, timely_worker: &mut TimelyWorker<A>, client_rx: Receiver<(Receiver<C>, UnboundedSender<R>, UnboundedSender<LocalActivator>)>, 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