laminar_core/checkpoint/
mod.rs

1//! Checkpoint barrier protocol and storage.
2//!
3//! Coordinator-triggered barriers flow through sources to trigger consistent
4//! state snapshots. The fast path is a single `AtomicU64` load (~10ns).
5
6/// Checkpoint barrier types and cross-thread injection.
7pub mod barrier;
8
9/// Unified checkpoint manifest types
10pub mod checkpoint_manifest;
11
12/// Checkpoint persistence trait and filesystem/object store implementations
13pub mod checkpoint_store;
14
15/// Object store factory — builds S3, GCS, Azure, or local backends from URL schemes.
16pub mod object_store_builder;
17
18pub use barrier::{
19    flags, BarrierPollHandle, CheckpointBarrier, CheckpointBarrierInjector, StreamMessage,
20};
21
22pub use checkpoint_manifest::{CheckpointManifest, ConnectorCheckpoint, OperatorCheckpoint};
23pub use checkpoint_store::{
24    CheckpointStore, CheckpointStoreError, FileSystemCheckpointStore, ObjectStoreCheckpointStore,
25    RecoveryReport, ValidationIssue, ValidationResult,
26};
laminar_core/checkpoint/mod.rs

laminar_core/checkpoint/
mod.rs
