Function mz_dataflow::server::serve_boundary_requests

source · [−]
pub fn serve_boundary_requests<SC: StorageCapture, CR: ComputeReplay, B: Fn(usize) -> (SC, CR) + Send + Sync + 'static>(
    config: Config, 
    requests: UnboundedReceiver<SourceInstanceRequest>, 
    create_boundary: B
) -> Result<(Server, BoundaryHook<LocalStorageClient>), Error>
Expand description

Initiates a timely dataflow computation, processing materialized commands.

  • create_boundary: A function to obtain the worker-local boundary components.