Module Algostream_data_ingestion

module Connection_supervisor : sig ... end

Per-connection state machine: connect attempts, exponential backoff with jitter, circuit breaker, liveness tracking, and rate-limited Risk_alert emission.

module Connector_runtime : sig ... end

Generic per-exchange runtime: connect over WebSocket, send the subscribe message, read frames in a loop, parse, validate, and publish into the bus. Backoff and circuit-breaking is delegated to Connection_supervisor.

module Data_quality : sig ... end

Real-time market-data quality monitors.

module Exchange : sig ... end

Abstract interface that each concrete exchange (Binance, Coinbase, …) implements.

module Ingestion_supervisor : sig ... end

Top-level supervisor for the market-data ingestion subsystem.

module Rate_limiter : sig ... end

Token-bucket rate limiter for outbound WebSocket control frames.

module Symbol_intern : sig ... end

Per-Domain string interning for symbols.