oxirs-stream 0.2.4

Real-time streaming support with Kafka/NATS/MQTT/OPC-UA I/O, RDF Patch, and SPARQL Update delta
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13

//! # Checkpoint Coordination
//!
//! Chandy-Lamport inspired distributed checkpoint coordinator for consistent
//! global snapshots and failure recovery.
//!
//! ## Modules
//!
//! - [`coordinator`]: `CheckpointCoordinator`, `GlobalCheckpoint`,
//!   `OperatorSnapshot`, and `CheckpointPhase`.

pub mod coordinator;

pub use coordinator::{CheckpointCoordinator, CheckpointPhase, GlobalCheckpoint, OperatorSnapshot};