mz_compute_client::controller::introspection

Function spawn_introspection_sink

Source 
pub fn spawn_introspection_sink<T: Timestamp>(
    rx: UnboundedReceiver<(IntrospectionType, Vec<(Row, Diff)>)>,
    storage_controller: &dyn StorageController<Timestamp = T>,
)
Expand description

Spawn a task sinking introspection updates produced by the compute controller to storage.