pub async fn run_engine_loop_stamped(
shell: ExecutionShell,
tick_rx: TickIngressReceiver,
tick_tx: TickIngressSender,
config: EngineConfig,
shutdown_rx: Receiver<()>,
)Expand description
生产指标入口:保持单一有界队列,在元素内携带真实入队时间戳。
pub async fn run_engine_loop_stamped(
shell: ExecutionShell,
tick_rx: TickIngressReceiver,
tick_tx: TickIngressSender,
config: EngineConfig,
shutdown_rx: Receiver<()>,
)生产指标入口:保持单一有界队列,在元素内携带真实入队时间戳。