Analytics at the
speed of events
Query event streams with 11.9us p99 latency. Projections, materialized views, and WebSocket streaming for dashboards that update in real-time. No ETL pipeline needed.
From ingestion to insight in microseconds
11.9us p99 Query Latency
DashMap concurrent reads deliver sub-microsecond indexed lookups. No query planner overhead, no connection pooling — just O(1) access to your event data.
Projections & Materialized Views
Define projections that automatically aggregate events into queryable views. Running totals, counters, session metrics — all updated in real-time as events arrive.
WebSocket Live Streaming
Subscribe to event streams over WebSocket. Dashboards update in real-time without polling. Filter by event type, entity, or custom predicates server-side.
DashMap Concurrent Reads
Lock-free concurrent hash map serves 40K+ queries per second. Multiple dashboard users querying simultaneously with no contention or degradation.
Parquet Columnar Storage
Historical data compresses into Parquet files with Snappy compression. Columnar layout means analytical queries scan only the columns they need.
Prometheus Metrics Built-In
Export event throughput, query latency percentiles, projection lag, and storage metrics directly to Prometheus. Grafana dashboards out of the box.
Query events in real-time
Time-range queries, projections, and live streaming — all from one API
# Query events in a time range — returns in microseconds
curl -s https://api.all-source.xyz/api/v1/events/query \
-H "Authorization: Bearer $API_KEY" \
-H "Content-Type: application/json" \
-d '{
"event_type": "page_view",
"start_time": "2026-04-16T00:00:00Z",
"end_time": "2026-04-16T23:59:59Z",
"limit": 1000
}'
# {"events": [...], "count": 847}
# Response time: 0.012ms (11.9us p99)
# Get a live projection — materialized view updated on every event
curl -s https://api.all-source.xyz/api/v1/projections/daily-active-users \
-H "Authorization: Bearer $API_KEY"
# {"projection": {"name": "daily-active-users", "value": 12847, ...}}
# Stream events in real-time via WebSocket
wscat -c "wss://api.all-source.xyz/api/v1/events/stream" \
-H "Authorization: Bearer $API_KEY"
# > {"subscribe": {"event_type": "page_view"}}
# < {"event": {"type": "page_view", "data": {...}, "timestamp": "..."}}Kill your ETL pipeline
Stop waiting for batch jobs. Query live event streams with sub-microsecond latency and stream updates to dashboards in real-time.