Skip to main content

tinyflow_api/
checkpoint.rs

1#[derive(Debug, Clone, Copy, PartialEq, Eq)]
2pub struct CheckpointContext {
3    pub checkpoint_id: u64,
4    pub timestamp_ms: u64,
5}
6
7impl CheckpointContext {
8    pub fn new(checkpoint_id: u64, timestamp_ms: u64) -> Self {
9        Self {
10            checkpoint_id,
11            timestamp_ms,
12        }
13    }
14}