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