Skip to main content

run_engine_loop_stamped

Function run_engine_loop_stamped 

Source
pub async fn run_engine_loop_stamped(
    shell: ExecutionShell,
    tick_rx: TickIngressReceiver,
    tick_tx: TickIngressSender,
    config: EngineConfig,
    shutdown_rx: Receiver<()>,
)
Expand description

生产指标入口:保持单一有界队列,在元素内携带真实入队时间戳。