Skip to main content

spawn_linearized_read_ts

mz_adapter::coord::sequencer::inner

Function spawn_linearized_read_ts 

Source 
fn spawn_linearized_read_ts<S>(
    oracle: Option<Arc<dyn TimestampOracle<Timestamp> + Send + Sync>>,
    name: &'static str,
    build_stage: impl FnOnce(Option<Timestamp>) -> S + Send + 'static,
) -> StageResult<Box<S>>
where
    S: Send + 'static,