Crate laminar_core

Expand description

Core streaming engine for LaminarDB.

Modules§

alloc: Priority class enforcement for the data path.
checkpoint: Distributed checkpoint barrier protocol. Checkpoint barrier protocol.
cluster: Distributed cluster coordination. Unstable: gated behind cluster-unstable. Cluster coordination: discovery and control plane.
error_codes: Structured error code registry (LDB-NNNN) and Ring 0 hot path error type. LaminarDB structured error code registry.
lookup: Lookup table types and predicate pushdown. Lookup table traits, predicate pushdown, and caching.
mv: Cascading materialized view registry with dependency tracking and cycle detection.
operator: Streaming operator types and window assigners for stream processing.
serialization: Shared Arrow IPC serialization for RecordBatch ↔ bytes. Shared serialization helpers.
shuffle: Cross-instance shuffle: message codec, credit flow, wire protocol. Cross-instance shuffle: one persistent TCP connection per peer pair, length-prefixed frames with a 1-byte tag. Backpressure is carried by the per-partition tokio mpsc on the consuming side.
state: Pluggable state backend (StateBackend trait + impls). 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).
streaming: In-memory streaming API — Source, Sink, Subscription with broadcast fan-out.
time: Event time, watermarks, and timer management.

debug_assert_priority: Assert that the current thread is running in the expected priority class.