Quant Intelligence
Turn raw market data into probability-based insights. From precomputed analytics to AI-powered natural language queries — the data layer that powers smart trading decisions.
Architecture
Client Layer
- Web App (React)
- Python SDK
- AI Query Engine
API Layer
- REST API
- WebSocket Streaming
- Analytics Endpoints
Processing Layer
- Rust Core (469K/s)
- Elixir Query Service
- Go Control Plane
Storage Layer
- Parquet Columnar
- WAL Durability
- Point-in-Time Snapshots
Technical Capabilities
Where does the data live?
32 partitionsApache Parquet files with SNAPPY compression, organized into 32 fixed partitions using consistent hashing.
- By Symbol: entity_id = 'NQ' or 'BTC'
- By Session: event_type tags for RTH/ETH
- By Date: Microsecond timestamp precision
How fast is time slicing?
11.9μs p9911.9μs indexed lookups with O(1) complexity. Generate 1-minute bars for a full trading session in under 10ms.
- Symbol lookup: 11.9μs (indexed)
- 1-minute bars (6.5 hrs): < 10ms
- Time range slice (1M events): < 5ms
How are corrections handled?
100% traceableImmutable append-only event sourcing with correction events. Full audit trails with as_of temporal queries.
- Original events are never modified
- Corrections appended with references
- as_of queries show pre-correction state
Can past analysis be reproduced?
Exact replayYes — automatic snapshots, as_of queries, and event replay engine ensure exact reproducibility.
- Snapshots: Every 100 events or 1 hour
- as_of queries: Point-in-time state
- Event Replay: Full deterministic replay
How easy is Python integration?
Multi-platformREST API ready with pandas-compatible responses. WebSocket streaming for real-time updates. SDK coming soon.
- REST API: GET /api/v1/events/query
- WebSocket: WS /api/v1/events/stream
- Returns JSON convertible to DataFrame
Does it support concurrent users?
40K+ qpsLock-free DashMap architecture handles 40K+ queries/sec with graceful latency degradation under load.
- 10 users: 12μs latency, ~83K qps
- 100 users: 15μs latency, ~66K qps
- 1000 users: 25μs latency, ~40K qps
API Design
AI Query Interface
Ask questions about market behavior in plain English. The AI translates your query into optimized analytics and returns probability-based answers.
WITH gap_days AS (
SELECT date, open, high, prev_close,
(open - prev_close) / prev_close * 100 AS gap_pct
FROM daily_bars
WHERE symbol = 'NQ'
AND EXTRACT(DOW FROM date) = 1
AND (open - prev_close) / prev_close * 100 > 0.5
)
SELECT
COUNT(*) AS total_samples,
SUM(CASE WHEN high > open THEN 1 ELSE 0 END) AS made_new_high,
AVG(CASE WHEN high > open THEN 1.0 ELSE 0.0 END) AS probability
FROM gap_daysBased on 52 samples over 5 years of Monday gap-up sessions for NQ:
Roadmap
Precomputed Analytics
- NQ/BTC probability distributions
- Basic regime classification
- Canned analytics queries
- < 10ms response times
Dynamic Query Engine
- Custom filter conditions
- Multi-symbol analysis
- Strategy backtesting
- Risk metrics calculation
AI-Powered Queries
- Natural language interface
- Auto-generated insights
- Strategy recommendations
- Anomaly detection alerts
Ready to Build Smarter?
Get early access to Quant Intelligence and start turning market data into probability-based insights.
