Exchange Markets
Collects normalized trades and builds market candles across centralized exchanges.
Point-in-time operational summary
This worker exposes a current loop-state record in this view. No multi-run history is requested or inferred.
Input to product surface
Consumes WebSocket and bounded REST trade streams from the configured centralized exchanges.
Converts source messages into the canonical trade format and removes duplicates.
Persists trades through the market-feed batch RPC with a safe per-trade fallback.
Updates market trades, source connections, and 1m, 5m, 15m, 1h, and 1d candles.
Powers market charts, volumes, pressure windows, source health, and the market snapshot on Overview.
The chain cannot produce its canonical output without these dependencies.
Configured public trade feeds for QUAI markets.
Required for trades, candles, connection state, and batch persistence.
Recovery, enrichment, transport, or coordination paths that do not replace the canonical source of truth.
Optional low-latency orderbook and snapshot transport.
Recovery and bounded historical fill when supported by an exchange.
Storage contract
Tables read or written by this worker chain.
Swipe horizontally to inspect all columns
| Table | Purpose |
|---|---|
| market_trades | Normalized and deduplicated exchange trades. |
| market_candles | Aggregated OHLC and volume windows. |
| market_feed_connections | Per-exchange runtime, message, trade, and reconnect health. |
Product outputs
User-facing workspaces directly powered by this chain.
Exchange source health unavailable
The Market Feed process can still be inspected, but its per-exchange connection state could not be loaded.
Latest exchange batch state
No checkpoint reported
The worker has not yet persisted a public checkpoint for this process instance.
Cycle metadata
No runtime metadata
This chain does not currently expose additional public cycle details.
Implementation map
Primary repository files implementing this worker chain and its product read path.