Skip to main content

laminar_core/checkpoint/
mod.rs

1//! # Distributed Checkpoint Module
2//!
3//! Chandy-Lamport style barrier protocol for consistent distributed snapshots.
4//!
5//! ## Module Overview
6//!
7//! - `barrier`: Checkpoint barrier types, `StreamMessage<T>` enum, and
8//!   cross-thread barrier injection
9//! - `unaligned`: Unaligned checkpoint protocol with optional timeout-based
10//!   semantics for alignment-less checkpointing
11
12/// Checkpoint barrier types and cross-thread injection.
13pub mod barrier;
14/// Unaligned checkpoint protocol with optional timeout-based semantics.
15pub mod unaligned;
16
17// Re-export key types
18pub use barrier::{
19    flags, BarrierPollHandle, CheckpointBarrier, CheckpointBarrierInjector, StreamMessage,
20};
21pub use unaligned::{
22    InFlightChannelData, UnalignedAction, UnalignedCheckpointConfig, UnalignedCheckpointer,
23    UnalignedSnapshot,
24};