Skip to content

Harden realtime market processing - #147

Merged
pjy008008 merged 3 commits into
developfrom
fix/realtime-market-production-readiness
Aug 7, 2026
Merged

Harden realtime market processing#147
pjy008008 merged 3 commits into
developfrom
fix/realtime-market-production-readiness

Conversation

@pjy008008

Copy link
Copy Markdown
Contributor

What changed

  • persist display-only 1m OHLCV history while retaining the 250ms realtime Redis Pub/Sub path
  • keep strategy evaluation on finalized 30m/1h/4h/1d events, including mixed cadence plans
  • isolate runtime sequence and feature state per instrument
  • drain excessive stream lag without stale orders, bound retries with a DLQ, ACK availability-denied events, and expose metrics
  • bound Redis stream/dedup storage and retry missing finalized candles

Why

The worker could deadlock while behind, poison entries could remain pending forever, and display candles had no restart-safe history.

Impact

Realtime charts receive low-latency updates plus durable minute bootstrap data. Strategy workers recover safely without replaying stale orders or accumulating unbounded Redis state.

Validation

  • ./gradlew.bat check
  • Redis/Testcontainers coverage for stream recovery, DLQ behavior, availability skips, OHLCV aggregation, and history trimming

@pjy008008
pjy008008 merged commit 5ed3c98 into develop Aug 7, 2026
2 checks passed
@pjy008008
pjy008008 deleted the fix/realtime-market-production-readiness branch August 7, 2026 20:31
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant