pub async fn serve(
timely_config: TimelyConfig,
metrics_registry: &MetricsRegistry,
persist_clients: Arc<PersistClientCache>,
txns_ctx: TxnsContext,
tracing_handle: Arc<TracingHandle>,
context: ComputeInstanceContext,
storage_log_readers: Vec<Arc<EventLink<Timestamp, Vec<(Duration, TimelyEvent)>>>>,
) -> Result<impl Fn() -> Box<dyn ComputeClient> + use<>, Error>Expand description
Initiates a timely dataflow computation, processing compute commands.