tinyflow-api 0.1.1

Core traits, types, and abstractions for Tinyflow streaming framework
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14

#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub struct CheckpointContext {
    pub checkpoint_id: u64,
    pub timestamp_ms: u64,
}

impl CheckpointContext {
    pub fn new(checkpoint_id: u64, timestamp_ms: u64) -> Self {
        Self {
            checkpoint_id,
            timestamp_ms,
        }
    }
}