Crate laminar_core 

Core streaming engine for LaminarDB.

Modules

alloc

Priority class enforcement for the data path.

checkpoint

Distributed checkpoint barrier protocol. Checkpoint barrier protocol.

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.

streaming

In-memory streaming API — Source, Sink, Subscription with broadcast fan-out.

time

Event time, watermarks, and timer management.

Macros

debug_assert_priority

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

Enums

Error

Error types for laminar-core

Type Aliases

Result

Result type for laminar-core operations