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
14
15
16
17
18
19
20
21

//! State backend abstraction. Two concrete backends:
//! `InProcessBackend` for embedded single-process runs, and
//! `ObjectStoreBackend` for anything durable (local filesystem via
//! `file://`, or S3/GCS/Azure).

pub mod backend;
pub mod config;
pub mod in_process;
pub mod object_store;
pub mod vnode;

pub use backend::{StateBackend, StateBackendError};
pub use config::{
    DiscoveryMode, StateBackendBuildError, StateBackendConfig, DEFAULT_VNODE_CAPACITY,
};
pub use in_process::InProcessBackend;
pub use object_store::ObjectStoreBackend;
pub use vnode::{
    key_hash, owned_vnodes, owners_per_domain, peer_owners, rendezvous_assignment, Locality,
    NodeId, VnodeLifecycleState, VnodeRegistry,
};