| title | status | last_updated | version |
|---|---|---|---|
AllSource Event Store - Monorepo |
CURRENT |
2026-02-16 |
0.10.5 |
High-performance event sourcing platform with distributed architecture and AI-native tooling.
| Get Started | Quick Start · Docker Guide · Troubleshooting |
| Architecture | Clean Architecture · Tenant Model · Replication Design |
| API & Specs | API Reference · Performance · Event Store Features |
| Operations | Release Guide · Quality Gates · WebSocket Config |
| Services | Core · Control Plane · Query Service · MCP Server · Web |
| Deploy | Helm Chart · Kubernetes · Fly.io |
Clients --> Query Service (Elixir, :3902) --> Core (Rust, :3900)
| |
Control Plane (Go, :3901) WAL + Parquet + DashMap
(auth, billing, policies) (events, projections,
snapshots, schemas)
Core IS the database. No PostgreSQL for events — just WAL (CRC32, fsync), Parquet (Snappy compression), and DashMap (concurrent in-memory reads). Zero external dependencies. Full architecture docs →
apps/
core/ # Rust event store — the database
control-plane/ # Go auth/billing/ops — the gatekeeper
query-service/ # Elixir API gateway — the router
mcp-server-elixir/ # MCP server (61 tools) — the AI interface
web/ # Next.js dashboard — the UI
deploy/
helm/ # Helm charts
k8s/ # Kubernetes manifests
cloudrun/ # Cloud Run configs
prometheus/ # Monitoring config
grafana/ # Grafana provisioning
tooling/
data-flow-test/ # E2E data flow test
durability-test/ # WAL/Parquet durability test
Full roadmap: Consolidated Roadmap · Known gaps: Roadmap P0
The database. Source of truth for all event data.
- 469K events/sec ingestion, 11.9us query latency
- WAL (CRC32, fsync) + Parquet (Snappy) + DashMap for durability and speed
- v0.10.4: persistence wiring fix — env vars now correctly configure WAL+Parquet on startup
- Leader-follower replication via WAL shipping (design)
- Schema registry, stream processing pipelines, multi-tenancy with RBAC
- Vector search (fastembed + HNSW) and BM25 keyword search (tantivy)
Go Control Plane (port 3901) — docs
Authentication, authorization, billing, and operational management.
- JWT auth & RBAC (4 roles, 7 permissions), policy enforcement with audit logging
- LemonSqueezy billing integration, HAL hypermedia API, OpenAPI spec
- OpenTelemetry distributed tracing
Stateless API gateway. Routes to Core, delegates auth to Control Plane.
- Fully stateless, no PostgreSQL dependency
- Tesla HTTP client with connection pooling, Broadway event processing
- OpenAPI specification via
open_api_spex
MCP Server (61 tools) — docs
AI-native interface for Claude Desktop or any MCP client.
- 61 tools across 11 categories (discover, search, drill-down, context, mutate, ops, tenants, schema, analytics, dev)
- TOON format responses (~50% fewer tokens than JSON)
Web Dashboard (port 3000) — docs
- Next.js 16 + TypeScript + React + Tailwind + shadcn/ui
- Events, API Keys, Billing, Pipelines, Settings pages
| Priority | Focus | Details |
|---|---|---|
| P0 | Fix existing gaps | 5 QS endpoints return 501, Core fork commit stubbed, MCP analytics are basic aggregations |
| P1 | SaaS launch | Fly.io deploy, LemonSqueezy products, JS/Python/Go SDKs, onboarding wizard |
| P2 | QS Phase 3 | Phoenix Channels WebSocket, Broadway Kafka/RabbitMQ, distributed mode |
| P3 | Future | Multi-node Raft, geo-replication (CRDT), EventQL query language, GraphQL |
All services ship at v0.10.4. Total production footprint: ~129 MB.
| Service | Image | Size | Base |
|---|---|---|---|
| Core | ghcr.io/all-source-os/allsource-core:0.10.4 |
15.7 MB | Distroless |
| Control Plane | ghcr.io/all-source-os/allsource-control-plane:0.10.4 |
27.9 MB | Distroless |
| Query Service | ghcr.io/all-source-os/allsource-query-service:0.10.4 |
35.1 MB | Alpine |
| Web | ghcr.io/all-source-os/allsource-web:0.10.4 |
~50 MB | Alpine |
# Quick start
docker compose up -d
# Pull specific version
docker pull ghcr.io/all-source-os/allsource-core:0.10.4See Docker Guide · Release Guide
- Rust 1.92+ · Go 1.24+ · Elixir 1.17+ (OTP 27+) · Bun 1.3+
git clone https://github.com/all-source-os/all-source.git
cd allsource-monorepo
docker compose up -d
# Or run individual services
cd apps/core && cargo run
cd apps/control-plane && go run .
cd apps/query-service && mix phx.servercd apps/core && cargo test --lib # 1466 tests
cd apps/control-plane && go test ./...
cd apps/query-service && mix test
cd apps/mcp-server-elixir && mix testmake quality-rust # fmt + clippy + test + doc
make quality-go # vet + lint + test
make quality-elixir # format + credo + test
make check-versions # Verify version consistencySee Quality Gates · Quality Gates Setup
| Service | File |
|---|---|
| Core | apps/core/Cargo.toml |
| Control Plane | apps/control-plane/main.go |
| Query Service | apps/query-service/mix.exs |
| MCP Server | apps/mcp-server-elixir/mix.exs |
| K8s Manifests | deploy/k8s/*.yaml |