Skip to main content

laminar_core/delta/
mod.rs

1//! # Delta: Distributed Coordination for LaminarDB
2//!
3//! This module implements multi-node distribution for LaminarDB, extending
4//! the single-process engine with gossip discovery, Raft metadata consensus,
5//! epoch-fenced partition ownership, distributed checkpointing, and gRPC
6//! inter-node RPC.
7//!
8//! ## Architecture
9//!
10//! ```text
11//! ┌─────────────┐    ┌─────────────┐    ┌─────────────┐
12//! │   Node A     │◄──►│   Node B     │◄──►│   Node C     │
13//! │  (Leader)    │    │  (Follower)  │    │  (Follower)  │
14//! └──────┬───────┘    └──────┬───────┘    └──────┬───────┘
15//!        │                   │                   │
16//!   ┌────▼────┐         ┌────▼────┐         ┌────▼────┐
17//!   │ Raft    │         │ Raft    │         │ Raft    │
18//!   │ (meta)  │         │ (meta)  │         │ (meta)  │
19//!   └────┬────┘         └────┬────┘         └────┬────┘
20//!        │                   │                   │
21//!   ┌────▼────┐         ┌────▼────┐         ┌────▼────┐
22//!   │Partition│         │Partition│         │Partition│
23//!   │ Guards  │         │ Guards  │         │ Guards  │
24//!   └─────────┘         └─────────┘         └─────────┘
25//! ```
26//!
27//! ## Modules
28//!
29//! - `discovery`: Node discovery (static seeds, gossip, Kafka groups)
30//! - `coordination`: Raft-based metadata consensus
31//! - `partition`: Epoch-fenced partition ownership and migration
32//! - `checkpoint`: Distributed checkpoint coordination
33//! - `rpc`: gRPC services for inter-node communication
34
35/// Node discovery and membership.
36pub mod discovery;
37
38/// Raft-based metadata consensus and coordination.
39pub mod coordination;
40
41/// Epoch-fenced partition ownership, assignment, and migration.
42pub mod partition;
43
44/// Distributed checkpoint coordination.
45pub mod checkpoint;