Module processor 

Structs

MetricsSummary

Metrics snapshot

OpenDeviationBarStream

Stream implementation for open deviation bars (true streaming)

StreamingMetrics

Streaming metrics for observability Issue #96 Task #6: Extended with queue depth and block time tracking

StreamingProcessor

Production streaming processor with bounded memory

StreamingProcessorConfig

Configuration for production streaming

Enums

StreamingError

Streaming errors