Model Router

Intelligent, explainable, cost- and latency-aware LLM request routing platform, AI Traffic Control Room, and drop-in SDKs.

The Real-World Problem

Companies building AI applications face ballooning API costs, rate limits, and latency spikes. They want to use large models (like GPT-4o, Claude 3.5 Sonnet, or JEV reasoning models) for complex reasoning, but cheaper/faster models (like Llama 3 or Haiku) for simple tasks. Manually writing logic to route these requests is brittle and hard to maintain.

Why it's Unique (The "Edge")

The "Traffic Control Room": A stunning frontend UI that makes routing decisions transparent and explainable. You don't just route; you see why a request went to a specific model.
100% Local & Self-Hosted: No data leaves the user's infrastructure.
A/B Policy Experimentation: Built-in tools to test different routing policies (e.g., "lowest cost" vs "balanced") and see projected savings.
Triple-Mode Analyzer: Fast deterministic heuristics (<3ms), semantic ONNX embedding classification, and LLM-based continuous complexity scoring.
Thompson Sampling RL Auto-Tuning: Contextual multi-armed bandit automatically adjusts model quality scores online based on real-time latency, throughput, and error rates.
Production-Ready Scalability: Database-agnostic (SQLite for local dev, PostgreSQL for production) with Redis Pub/Sub powering real-time SSE traffic telemetry across distributed worker nodes.
Resilient Execution: Built-in sliding-window circuit breaker dynamically bypasses failing upstream providers to prevent cascading latency spikes.
Enterprise Observability: Standardized OpenTelemetry distributed tracing and native Prometheus /metrics exposition.

Key Features

Triple-Mode Request Analyzer: Deterministic heuristics (<3ms latency overhead), ONNX dense semantic embedding similarity, and continuous complexity scoring (0.05 to 0.99).
Explainable Multi-Criteria Routing Engine: Normalized 0-100 scoring across Quality, Cost Efficiency, Speed, Capabilities, and Reliability with transparent decision factor reports and candidate rejection logs.
Thompson Sampling RL Auto-Tuner: Online Beta-distribution bandit exploration and exploitation that dynamically refines candidate priors based on real-world feedback.
Multi-Tenant Workspaces & Rate Limiting: Workspace tenant isolation, cryptographically hashed API keys (mr_live_...), and sliding-window token-bucket rate limiters.
Provider Abstraction: Decoupled adapters for Mock (simulation), Ollama (local), OpenAI, Anthropic, Together AI, DeepSeek, Groq, and Google Gemini.
Resilience and Tiered Fallback: Automated retry classification for transient errors (timeouts, HTTP 429, 503) and tiered fallback to local/mock alternatives with circuit breaker protection.
Automated Benchmarking & Pareto Evaluator: Run GSM8K, HumanEval, and MMLU benchmarks via CLI and compute 3D Cost-Accuracy Pareto frontiers with ASCII curve visualizers.
OpenTelemetry & Prometheus Observability: Distributed trace span propagation across routing stages, plus Prometheus metrics scraping at /metrics.
Traffic Control Room UI: Real-time operational interface with dark/light mode, live topology graphs, playground inspector, SSE live request stream, telemetry export as CSV/JSON, visual rules builder, and cost savings simulator.
Drop-In Client SDKs: Native Python (modelrouter-sdk) and TypeScript/JavaScript (@picadolabs/modelrouter-sdk) libraries for 1-line OpenAI client replacement.

System Architecture & End-to-End Workflow

flowchart TD
    classDef client fill:#1e293b,stroke:#38bdf8,stroke-width:2px,color:#f8fafc;
    classDef gateway fill:#0f172a,stroke:#818cf8,stroke-width:2px,color:#f8fafc;
    classDef intel fill:#1e1b4b,stroke:#a855f7,stroke-width:2px,color:#f8fafc;
    classDef exec fill:#064e3b,stroke:#34d399,stroke-width:2px,color:#f8fafc;
    classDef obs fill:#431407,stroke:#fb923c,stroke-width:2px,color:#f8fafc;

    subgraph CLIENTS["1. INGESTION & CLIENTS"]
        SDK["Python & TypeScript SDKs<br/><code>modelrouter-sdk</code>"]:::client
        CLI["Typer CLI<br/><code>modelrouter</code>"]:::client
        UI["Traffic Control Room<br/><code>React / Vite UI</code>"]:::client
        REST["OpenAI Drop-In API<br/><code>POST /api/generate</code>"]:::client
    end

    subgraph GATEWAY["2. GATEWAY & ACCESS CONTROL"]
        AUTH["Tenant Auth & Workspace Isolation<br/><code>Bearer mr_live_...</code>"]:::gateway
        RL["Sliding-Window Rate Limiter<br/><code>Token Bucket Algorithm</code>"]:::gateway
        OTEL_CTX["OpenTelemetry Baggage Context<br/><code>Span Propagation</code>"]:::gateway
    end

    subgraph INTELLIGENCE["3. INTELLIGENT ROUTING PIPELINE"]
        ANALYZER["Triple-Mode Analyzer<br/>• Fast Heuristics (&lt;3ms)<br/>• ONNX Semantic Embeddings<br/>• Continuous Complexity (0.05 - 0.99)"]:::intel
        PRUNE["Rules & Candidate Pruner<br/>• Context Window & Capability Match<br/>• Explicit Rule Overrides"]:::intel
        SCORER["Multi-Criteria Scoring Engine<br/>• Weighted Quality, Speed, Cost, Reliability<br/>• Contextual Thompson Sampling Bandit RL"]:::intel
        EXPLAIN["Explainability Engine<br/>• Transparent Decision Factors & Rejections"]:::intel
    end

    subgraph RESILIENCE["4. EXECUTION & RESILIENCE LAYER"]
        CB["Sliding-Window Circuit Breaker<br/><code>Auto-bypass failing endpoints</code>"]:::exec
        FALLBACK["Tiered Fallback Supervisor<br/><code>Automatic retry & failover</code>"]:::exec
        
        subgraph PROVIDERS["Provider Adapters"]
            CLOUD["Frontier Models<br/><code>OpenAI, Anthropic, Gemini, DeepSeek, Groq, Together</code>"]:::exec
            LOCAL["Local Inference<br/><code>Ollama / Qwen, Llama 3, DeepSeek-R1</code>"]:::exec
            MOCK["Zero-Cost Simulation<br/><code>In-Memory Mock Engine</code>"]:::exec
        end
    end

    subgraph STORAGE["5. OBSERVABILITY & STORAGE ENGINE"]
        PROM["Prometheus Metrics<br/><code>/metrics Scraping Endpoint</code>"]:::obs
        DB[(Database WAL<br/><code>SQLite / PostgreSQL</code>)]:::obs
        REDIS["Redis Pub/Sub Event Bus<br/><code>Live SSE Traffic Stream</code>"]:::obs
    end

    CLIENTS --> GATEWAY
    GATEWAY --> INTELLIGENCE
    INTELLIGENCE --> RESILIENCE
    RESILIENCE --> STORAGE
    REDIS -.->|Real-Time SSE Feed| UI

Supported Platforms & Prerequisites

Supported Platforms

Linux (Ubuntu 20.04+, Debian 11+, Fedora)
macOS (macOS 12+ / Apple Silicon & Intel)
Windows (Windows 10, Windows 11 / PowerShell & WSL2)

Prerequisites

Python 3.10, 3.11, or 3.12
Node.js 18+ and npm
(Optional) Ollama for local model inference

📦 Quick Installation (via PyPI)

Install Model Router and its embedded AI Traffic Control Room dashboard directly from PyPI:

pip install model-router-cli

Quick Commands:

# Run system diagnostics & environment checks
modelrouter doctor

# Launch the Traffic Control Room Dashboard & API Gateway in your browser
modelrouter ui --open-browser

# Route a prompt and inspect the explainability decision (Dry Run)
modelrouter route "Write an optimized async task worker in Python"

# Run automated GSM8K benchmark and evaluate Cost-Accuracy Pareto Frontier
modelrouter benchmark --dataset gsm8k --limit 10

Installation & Setup (from Source)

1. Clone the Repository

git clone https://github.com/PicadoLabs/ai-model-router.git
cd ai-model-router

2. Backend Installation

# Create and activate virtual environment
python -m venv venv
# On Linux/macOS:
source venv/bin/activate
# On Windows PowerShell:
.\venv\Scripts\Activate.ps1

# Install Python dependencies
pip install -r requirements.txt

# Create environment file from template
cp .env.example .env

3. Frontend Installation

# Enter the frontend directory
cd frontend

# Install frontend dependencies
npm install

# Return to the repository root
cd ..

Client SDKs (Python & TypeScript)

Model Router provides official lightweight, zero-dependency client libraries for drop-in routing in Python and Node.js/Browser applications.

🐍 Python SDK (`modelrouter-sdk`)

pip install modelrouter-sdk

from modelrouter import ModelRouter

# Initialize drop-in client
client = ModelRouter(base_url="http://localhost:8000", policy="balanced")

# 1. Standard OpenAI drop-in completion
response = client.chat.completions.create(
    messages=[{"role": "user", "content": "Explain Dijkstra's algorithm"}]
)
print("Routed Model:", response.model)
print("Content:", response.choices[0].message.content)

# 2. Real-time streaming
for chunk in client.chat.completions.create(prompt="Write a Python script", stream=True):
    if chunk.choices[0].delta.content:
        print(chunk.choices[0].delta.content, end="", flush=True)

# 3. Dry-run explainability inspector
decision = client.route("Design a distributed caching architecture")
print(f"Selected: {decision.selected_model_name} (Confidence: {decision.confidence*100:.0f}%)")

⚡ TypeScript & JavaScript SDK (`@picadolabs/modelrouter-sdk`)

npm install @picadolabs/modelrouter-sdk

import { ModelRouter } from '@picadolabs/modelrouter-sdk';

const router = new ModelRouter({
  baseUrl: 'http://localhost:8000',
  policy: 'balanced', // 'balanced' | 'cost_optimized' | 'speed_optimized' | 'quality_first'
});

// 1. Chat Completion
const response = await router.chat.completions.create({
  messages: [{ role: 'user', content: 'What is the speed of light in vacuum?' }]
});
console.log('Response:', response.choices[0].message.content);
console.log('Routed Model:', response.model);

// 2. Real-Time Streaming
const stream = await router.chat.completions.create({
  prompt: 'Write a quicksort in TypeScript',
  stream: true
});
for await (const chunk of stream) {
  process.stdout.write(chunk.choices[0]?.delta?.content || '');
}

CLI Usage

The built-in Typer CLI provides terminal commands for inspection, diagnostics, benchmarking, and testing:

# Launch the AI Traffic Control Room Web UI and API Gateway
modelrouter ui --open-browser

# Run system diagnostics & provider health checks
modelrouter doctor

# Inspect routing decision for a prompt without executing (Dry Run)
modelrouter route "Write a Python function to parse JSON"

# Route and execute a query through the selected model
modelrouter run "Debug this distributed async deadlock in worker pool"

# Run automated Pareto benchmark suite (GSM8K, HumanEval, MMLU)
modelrouter benchmark --dataset gsm8k --limit 10 --format table

# List all registered models in the catalog
modelrouter models

# View recent routed traffic logs
modelrouter traffic

# View system-wide routing performance and cost savings analytics
modelrouter analytics

REST API Usage

1. Dry-Run Routing (`POST /api/route`)

curl -X POST http://127.0.0.1:8000/api/route \
  -H "Content-Type: application/json" \
  -d '{"prompt": "Write a quicksort algorithm in Python", "policy": "balanced"}'

2. End-to-End Routed Generation (`POST /api/generate`)

curl -X POST http://127.0.0.1:8000/api/generate \
  -H "Content-Type: application/json" \
  -d '{"prompt": "Explain the difference between TCP and UDP", "policy": "cost_optimized"}'

3. Prometheus Metrics Endpoint (`GET /metrics`)

curl http://127.0.0.1:8000/metrics

4. Run Automated Pareto Benchmark (`POST /api/benchmarks/run`)

curl -X POST http://127.0.0.1:8000/api/benchmarks/run \
  -H "Content-Type: application/json" \
  -d '{"dataset": "gsm8k", "limit": 10, "baseline_model": "gpt-4o"}'

5. Export Historical Traffic (`GET /api/traffic/export`)

# Export as JSON
curl -OJ "http://127.0.0.1:8000/api/traffic/export?format=json"

# Export as CSV
curl -OJ "http://127.0.0.1:8000/api/traffic/export?format=csv"

Running Tests

The test suite includes 170 automated unit, integration, and end-to-end tests covering semantic embedding classification, Thompson sampling RL auto-tuning, OpenTelemetry & Prometheus metrics, benchmarking Pareto evaluator, SDK clients, and circuit breakers:

# Run the complete test suite from repository root
pytest

# Run tests with detailed coverage
pytest --cov=backend/app

Project Structure

ai-model-router/
├── .github/
│   └── workflows/ci.yml     # Continuous integration & test workflow
├── backend/
│   ├── app/
│   │   ├── analytics/       # Cost savings and aggregate analytics service
│   │   ├── analyzer/        # Triple-mode request analyzer (heuristics, semantic ONNX, LLM)
│   │   ├── api/             # FastAPI REST endpoints and request handlers
│   │   ├── auth/            # Multi-tenant API keys & token bucket rate limiter
│   │   ├── budgets/         # Spend tracking and automated threshold manager
│   │   ├── cli/             # Typer CLI application (doctor, route, benchmark, ui)
│   │   ├── config/          # Pydantic Settings environment configuration
│   │   ├── experiments/     # Benchmarking suite & Cost-Accuracy Pareto evaluator
│   │   ├── fallback/        # Error classifier, circuit breaker & tiered fallback supervisor
│   │   ├── models/          # Pydantic schemas (RequestAnalysis, RoutingDecision)
│   │   ├── observability/   # Prometheus metrics exporter & OpenTelemetry tracer
│   │   ├── providers/       # Adapters (Mock, Ollama, OpenAI, Anthropic, Gemini, DeepSeek, Groq)
│   │   ├── router/          # Scoring matrix, pruner, rules engine & Thompson Sampling RL
│   │   └── storage/         # SQLAlchemy models and SQLite async database
│   ├── tests/               # Pytest suite (170 passing tests)
│   └── main.py              # FastAPI application entrypoint
├── frontend/
│   ├── src/
│   │   ├── components/      # UI components (Navbar, RoutingMap topology graph)
│   │   ├── pages/           # Control Room pages (Dashboard, Playground, Rules, etc.)
│   │   └── types/           # TypeScript data interfaces
│   └── package.json         # Node.js dependencies
├── sdk/
│   ├── python/              # Official Python SDK (modelrouter-sdk)
│   └── typescript/          # Official TypeScript SDK (@picadolabs/modelrouter-sdk)
├── examples/                # Standalone SDK quickstart scripts
├── pyproject.toml           # Project build metadata
├── requirements.txt         # Root Python dependencies
└── README.md                # Project documentation

License

This project is licensed under the Apache License 2.0 - see the LICENSE file for details.

PicadoLabs

Maintained and architected by PicadoLabs.

Maintainer: @Kaap10
Organization: PicadoLabs
Website: https://picadolabs.me
Contact: [email protected]

Name		Name	Last commit message	Last commit date
.github		.github
alembic		alembic
backend		backend
examples		examples
frontend		frontend
scripts		scripts
sdk		sdk
.env.example		.env.example
.gitignore		.gitignore
CODE_OF_CONDUCT.md		CODE_OF_CONDUCT.md
CONTRIBUTING.md		CONTRIBUTING.md
Dockerfile		Dockerfile
GITHUB_ISSUES.md		GITHUB_ISSUES.md
LICENSE		LICENSE
README.md		README.md
SECURITY.md		SECURITY.md
alembic.ini		alembic.ini
docker-compose.yml		docker-compose.yml
new_issues.md		new_issues.md
pyproject.toml		pyproject.toml
pytest.ini		pytest.ini
requirements.txt		requirements.txt

Navigation Menu

Repository navigation

About

Repository files navigation

Model Router

The Real-World Problem

Why it's Unique (The "Edge")

Key Features

System Architecture & End-to-End Workflow

Supported Platforms & Prerequisites

Supported Platforms

Prerequisites

📦 Quick Installation (via PyPI)

Quick Commands:

Installation & Setup (from Source)

1. Clone the Repository

2. Backend Installation

3. Frontend Installation

Client SDKs (Python & TypeScript)

🐍 Python SDK (`modelrouter-sdk`)

⚡ TypeScript & JavaScript SDK (`@picadolabs/modelrouter-sdk`)

CLI Usage

REST API Usage

1. Dry-Run Routing (`POST /api/route`)

2. End-to-End Routed Generation (`POST /api/generate`)

3. Prometheus Metrics Endpoint (`GET /metrics`)

4. Run Automated Pareto Benchmark (`POST /api/benchmarks/run`)

5. Export Historical Traffic (`GET /api/traffic/export`)

Running Tests

Project Structure

License

PicadoLabs

About

Releases

Packages

Contributors

Languages

Latest commit

History

Folders and files

Repository files navigation

Model Router

The Real-World Problem

Why it's Unique (The "Edge")

Key Features

System Architecture & End-to-End Workflow

Supported Platforms & Prerequisites

Supported Platforms

Prerequisites

📦 Quick Installation (via PyPI)

Quick Commands:

Installation & Setup (from Source)

1. Clone the Repository

2. Backend Installation

3. Frontend Installation

Client SDKs (Python & TypeScript)

🐍 Python SDK (modelrouter-sdk)

⚡ TypeScript & JavaScript SDK (@picadolabs/modelrouter-sdk)

CLI Usage

REST API Usage

1. Dry-Run Routing (POST /api/route)

2. End-to-End Routed Generation (POST /api/generate)

3. Prometheus Metrics Endpoint (GET /metrics)

4. Run Automated Pareto Benchmark (POST /api/benchmarks/run)

5. Export Historical Traffic (GET /api/traffic/export)

Running Tests

Project Structure

License

PicadoLabs

About

Topics

Resources

Code of conduct

Contributing

Security policy

Stars

Watchers

Forks

Releases

Packages

Contributors

Languages

🐍 Python SDK (`modelrouter-sdk`)

⚡ TypeScript & JavaScript SDK (`@picadolabs/modelrouter-sdk`)

1. Dry-Run Routing (`POST /api/route`)

2. End-to-End Routed Generation (`POST /api/generate`)

3. Prometheus Metrics Endpoint (`GET /metrics`)

4. Run Automated Pareto Benchmark (`POST /api/benchmarks/run`)

5. Export Historical Traffic (`GET /api/traffic/export`)