laminar-core 0.26.0

Core streaming engine for LaminarDB - operators, checkpoint barriers, and streaming primitives
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13

//! Cluster coordination: discovery and control plane.

/// Node discovery and membership.
pub mod discovery;

/// Control plane: leader election, assignment snapshots, barrier
/// coordination.
pub mod control;

/// In-process harness for cluster integration tests. Gated because
/// it pulls in chitchat on loopback UDP.
#[cfg(feature = "cluster")]
pub mod testing;