Crate laminar_core 

LaminarDB Core

The core streaming engine for LaminarDB.

This crate provides:

• Operators: Streaming operators (map, filter, window, join)
• DAG: Dataflow graph execution and checkpoint coordination
• State Store: Lock-free state management with sub-microsecond lookup
• Time: Event time processing, watermarks, and timers
• Streaming: SPSC/MPSC channels, sources, sinks, subscriptions

Design Principles

1. Zero allocations on hot path - Uses arena allocators
2. No locks on hot path - SPSC queues, lock-free structures
3. Predictable latency - < 1μs event processing
4. CPU cache friendly - Data structures optimized for cache locality

Modules

alloc

Allocation guards and priority class enforcement for the data path.

checkpoint

Distributed checkpoint barrier protocol.

dag

DAG Pipeline Topology

delta

Distributed delta mode (multi-node coordination).

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.

mv

Cascading Materialized Views

operator

Operator Module

serialization

Shared Arrow IPC serialization for RecordBatch ↔ bytes. Shared serialization helpers.

state

State Store Module

streaming

Streaming API

subscription

Reactive Subscription System

time

Time Module

Macros

debug_assert_priority

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

hot_path

Macro to mark a function as hot path.

Enums

Error

Error types for laminar-core

Type Aliases

Result

Result type for laminar-core operations