Skip to main content

tinyflow_framework/runtime/
control_msg.rs

1#[derive(Debug, Clone, PartialEq)]
2pub enum ControlMsg {
3    Checkpoint(u64),
4    CheckpointEnd(u64),
5    Ack(u64, u32),
6}
7
8pub type ControlSender = tokio::sync::mpsc::Sender<ControlMsg>;
9pub type ControlReceiver = tokio::sync::mpsc::Receiver<ControlMsg>;