Module streaming

Streaming Window Index — RFC-008 Phase 3.

Combines a hot buffer (brute-force, fast writes) with a compacted partitioned HNSW (graph-based, fast reads) for streaming workloads.

Write path:
  Insert → HotBuffer (flat scan) → [compaction] → PartitionedHnsw

Read path:
  Query → [HotBuffer results] ∪ [PartitionedHnsw results] → merge → top-k

Structs

BufferedPoint 🔒

A point in the hot buffer.

HotBuffer 🔒

A flat buffer for recent, not-yet-compacted points.

StreamingConfig

Configuration for the streaming index.

StreamingTemporalHnsw

Streaming temporal index that combines a hot buffer with a compacted partitioned HNSW index.