Skip to main content

spawn_serial_timer_lane

risingwave_meta::hummock::manager::timer_task

Function spawn_serial_timer_lane 

Source 
fn spawn_serial_timer_lane<E, F, Fut>(
    name: &'static str,
    triggers: Vec<BoxStream<'static, E>>,
    shutdown_rx: Receiver<bool>,
    handler: F,
) -> JoinHandle<()>
where
    E: Send + 'static,
    F: FnMut(E) -> Fut + Send + 'static,
    Fut: Future<Output = ()> + Send + 'static,
Expand description

Spawn a lane with multiple timers whose handlers must stay serialized.