pub async fn serve(
timely_config: TimelyConfig,
metrics_registry: &MetricsRegistry,
persist_clients: Arc<PersistClientCache>,
txns_ctx: TxnsContext,
tracing_handle: Arc<TracingHandle>,
now: NowFn,
connection_context: ConnectionContext,
instance_context: StorageInstanceContext,
timely_log_writers: Vec<Arc<EventLink<Timestamp, Vec<(Duration, TimelyEvent)>>>>,
) -> Result<impl Fn() -> Box<dyn StorageClient> + use<>, Error>Expand description
Initiates a timely dataflow computation, processing storage commands.