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()?;