Crate laminar_core 

LaminarDB Core

The core streaming engine for LaminarDB, implementing the Ring 0 (hot path) components.

This crate provides:

• Reactor: Single-threaded event loop with zero allocations
• Operators: Streaming operators (map, filter, window, join)
• State Store: Lock-free state management with sub-microsecond lookup
• Time: Event time processing, watermarks, and timers

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

Example

use laminar_core::{Reactor, Config};

let config = Config::default();
let mut reactor = Reactor::new(config)?;

// Run the event loop
reactor.run()?;

Re-exports

pub use reactor::Reactor;

pub use reactor::ReactorConfig;

Modules

alloc

Zero-allocation enforcement for Ring 0 hot path.

budget

Task Budget Enforcement

dag

DAG Pipeline Topology

detect

Automatic Hardware/Software Feature Detection

io_uring

io_uring Advanced Optimization (F067)

mv

Cascading Materialized Views (F060)

numa

NUMA-Aware Memory Allocation

operator

Operator Module

reactor

Reactor Module

sink

Exactly-Once Sinks (F023)

state

State Store Module

streaming

Streaming API

subscription

Reactive Subscription System

time

Time Module

tpc

Thread-Per-Core (TPC) Module

xdp

XDP/eBPF Network Optimization (F072)

Macros

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