Trait 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>, UnboundedSender<Self::Activatable>)>,
        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 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>, 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