laminar-core 0.20.2

Core streaming engine for LaminarDB - operators, checkpoint barriers, and streaming primitives
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

# laminar-core

Core streaming engine for LaminarDB — operators, checkpoint barriers, and streaming infrastructure.

## Modules

| Module | Purpose |
|--------|---------|
| `operator` | Window assigners, table cache, changelog/Z-set types |
| `time` | Event time extraction, watermark generators |
| `streaming` | Source/Sink/Subscription API backed by crossfire channels |
| `checkpoint` | Barrier protocol for consistent snapshots |
| `lookup` | Lookup table trait, predicate pushdown, foyer cache |
| `mv` | Cascading materialized views |
| `alloc` | Priority-class enforcement (debug builds) |
| `error_codes` | Structured `LDB-NNNN` error codes and `HotPathError` |
| `serialization` | Shared Arrow IPC serialization |
| `delta` | (optional) Distributed coordination, gossip discovery |

## Benchmarks

```bash
cargo bench -p laminar-core --bench streaming_bench    # Channel and source throughput
cargo bench -p laminar-core --bench window_bench       # Window operations
cargo bench -p laminar-core --bench lookup_join_bench  # Lookup join throughput
cargo bench -p laminar-core --bench cache_bench        # foyer cache hit/miss
cargo bench -p laminar-core --bench latency_bench      # End-to-end event latency
```