feat(streaming): add connection health monitoring

[AKKI0511]

Summary

• implement StreamingHealthMonitor with latency checks, throughput metrics and reconnection handling
• add alert, metrics collector and recovery manager utilities
• integrate health monitoring into streaming gateway and configuration
• add tests for alerting and reconnection logic

Testing

• poetry run pre-commit run --files config/streaming.yaml quanttradeai/streaming/__init__.py quanttradeai/streaming/gateway.py quanttradeai/streaming/monitoring/__init__.py quanttradeai/streaming/monitoring/health_monitor.py quanttradeai/streaming/monitoring/alerts.py quanttradeai/streaming/monitoring/metrics_collector.py quanttradeai/streaming/monitoring/recovery_manager.py tests/streaming/test_health_monitor.py
• PYTHONPATH=. pytest tests/streaming/test_health_monitor.py

---

https://chatgpt.com/codex/tasks/task_e_68b22602cfb4832aafd8ff80439bbcf6

[chatgpt-codex-connector]

Codex Review: Here are some suggestions.

Reply with @codex fix comments to fix any unresolved comments.

About Codex in GitHub

Your team has set up Codex to review pull requests in this repo. Reviews are triggered when you open a pull request for review, mark a draft as ready, or comment "@codex review". If Codex has suggestions, it will comment; otherwise it will react with 👍.

Codex can also answer questions or update the PR. Try commenting "@codex fix this CI failure" or "@codex address that feedback".

[cursor]

Bugbot found 1 bug

To see it, activate your membership in the Cursor dashboard.

[AKKI0511]

@codex fix this CI failure

[chatgpt-codex-connector]

Summary

• Reset connection state after a successful recovery by updating both window_start and last_message_ts, preventing the monitor from immediately flagging the connection as stalequanttradeai/streaming/monitoring/health_monitor.pyL132-L145
• Added a regression test confirming last_message_ts is refreshed on reconnect, ensuring the monitor no longer loops into repeated recoveries without new traffictests/streaming/test_health_monitor.pyL90-L110

Testing

• ✅ SKIP=test poetry run pre-commit run --files config/streaming.yaml quanttradeai/streaming/__init__.py quanttradeai/streaming/gateway.py quanttradeai/streaming/monitoring/__init__.py quanttradeai/streaming/monitoring/health_monitor.py quanttradeai/streaming/monitoring/alerts.py quanttradeai/streaming/monitoring/metrics_collector.py quanttradeai/streaming/monitoring/recovery_manager.py tests/streaming/test_health_monitor.py
• ✅ poetry run pytest tests/streaming/test_health_monitor.py

View task →