tinyflow-framework 0.1.1

Streaming runtime engine — checkpoint, chained task execution, and state store
Documentation 
1
2
3
4
5
6
7
8
9

#[derive(Debug, Clone, PartialEq)]
pub enum ControlMsg {
    Checkpoint(u64),
    CheckpointEnd(u64),
    Ack(u64, u32),
}

pub type ControlSender = tokio::sync::mpsc::Sender<ControlMsg>;
pub type ControlReceiver = tokio::sync::mpsc::Receiver<ControlMsg>;