Architecture

Real-time Layer

The real-time layer ensures dashboards, traders, and automated strategies see the same data the coordination network sees. It is optimized for sub-second updates and degrades gracefully if a single source of truth fails.

Streams

  • slotStream: emits every new Solana slot plus reservation metadata.
  • auctionStream: pushes bid/ask changes, clearing events, and anti-sniping extensions.
  • executionStream: surfaces confirmations, failures, and latency measurements.
  • rpcMonitor: distributes drift metrics, endpoint failover decisions, and alerts.

Subscription Example

slotStream.ts
import { getSlotStream } from '@/lib/realtime/slotStream'

const stream = getSlotStream()

stream.on('data', (slot) => {
  console.log('latest slot', slot.slotNumber)
})

stream.start()

Failover Policy

Streams run in multiple regions. If a WebSocket disconnects, the SDK automatically falls back to REST polling and marks integrity status as degraded. Observability dashboards display slot drift and WebSocket stalls so operations teams can respond instantly.