mirror of
https://github.com/BerriAI/litellm.git
synced 2026-09-16 23:41:43 +00:00
* feat(proxy): add logging_endpoints package init
* feat(proxy): add POST /v1/callbacks/logs to replay logging payloads through the success/failure callback fan-out
* feat(proxy): register callback_logs_router
* test(proxy): add logging_endpoints test package init
* test(proxy): cover /v1/callbacks/logs replay, admin guard, and partial-failure handling
* refactor(proxy): move callback-logs request/response models to litellm/types/proxy
* refactor(proxy): wrap callback-logs replay in CallbackLogsReplayer class with payload logging
* test(proxy): update callback-logs tests for class-based replayer and separated types
* fix(proxy): cover /v1/callbacks/ in backend component allowlist
The new /v1/callbacks/logs route was dropped by both component
allowlists, failing test_gateway_plus_backend_covers_full_app. It's an
admin-only spend-logging route, so it belongs on the backend (control
plane) alongside the existing /callbacks family.
* refactor(proxy): use builtin dict/list generics in callback-logs endpoint
Switch Dict/List from typing to builtin dict/list to satisfy the ruff
strict-rule budget (UP006).
* refactor(proxy): use builtin dict/list generics in callback-logs types
UP006: builtin generics over typing.Dict/List.
* chore(ui): regenerate schema.d.ts for /v1/callbacks/logs
Run npm run gen:api to add the CallbackLogRecord/CallbackLogsRequest/
CallbackLogsResponse types and the /v1/callbacks/logs path, keeping the
dashboard types in sync with the proxy OpenAPI spec.
* fix(proxy): force stream=False when replaying callback logs
A replayed StandardLoggingPayload is a terminal, fully-aggregated event —
the producer (e.g. the rust realtime gateway) already collected the whole
session before POSTing. Marking the rebuilt Logging object as streaming made
async_success_handler wait for a complete_streaming_response that never
arrives, so the spend log was never written. Realtime sessions now land in
LiteLLM_SpendLogs.
* feat(litellm-rust): CustomLogger callback layer posting to /v1/callbacks/logs
integrations/ mirrors litellm/integrations/: a sync, typed CustomLogger trait
(base contract), a typed StandardLoggingPayload, and LiteLLMPythonProxyAPILogger
— the first concrete logger, owning a bounded channel + background worker that
batches and POSTs to the Python proxy's /v1/callbacks/logs.
* feat(litellm-rust): RealTimeStreaming per-session log collector
1:1 with Python's RealTimeStreaming: observe() accumulates O(1) usage/model/id
per event (never buffers frames); log_messages() builds one StandardLoggingPayload
on session close and fans out to the CustomLogger callbacks. request_id == the
OpenAI realtime session id (sess_…), with the gateway id as fallback.
* feat(litellm-rust): wire realtime logging into the splice (lock-free observe)
The collector is owned on the splice task and observed via a synchronous &mut
callback threaded through providers::realtime::realtime() — no Arc/Mutex/atomic
on the per-frame hot path. On session close the bridge flushes one payload.
AppState carries the registered loggers; main spawns the proxy logger.
* docs(litellm-rust): ai-gateway realtime logging architecture
* docs(litellm-rust): document request-log egress to the LiteLLM control plane
Add a 'Request logging' guide to the ai-gateway README: how to point the gateway
at a LiteLLM proxy via LITELLM_PROXY_BASE_URL (+ LITELLM_MASTER_KEY for the
admin-only /v1/callbacks/logs POST), and the non-blocking / one-payload-per-session
behavior.
* feat(litellm-rust): make log-egress tunables env-overridable
Channel capacity, batch size, and flush interval now read from
LITELLM_LOG_CHANNEL_CAPACITY / LITELLM_LOG_BATCH_SIZE / LITELLM_LOG_FLUSH_INTERVAL_MS,
falling back to the DEFAULT_* consts on missing/invalid/non-positive values.
Grouped behind an EgressTunables::from_env() read once at logger construction.
* docs(litellm-rust): document log-egress tuning env vars
* docs(litellm-rust): require constants in a crate-level constants.rs
Mirror of Python's litellm/constants.py rule — magic numbers and fixed strings
go in src/constants.rs, not inline in feature modules; env-overridable tunables
keep their DEFAULT_* value there.
* refactor(litellm-rust): move ai-gateway constants into constants.rs
Per the new rule: the log-egress defaults (proxy base, ingest path, channel
capacity, batch size, flush interval) and the realtime provider default move to
crates/ai-gateway/src/constants.rs; modules import from it.
* ci: run logging_endpoints tests in the proxy-infra coverage shard
tests/test_litellm/proxy/logging_endpoints wasn't in any coverage-uploading
job, so callback_logs_endpoints.py showed only import-level coverage (~35%) on
codecov/patch despite being ~98% covered locally. Add it to proxy-infra's
test-path so the test is exercised under --cov.
* fix(litellm-rust): hash the master key before logging — never send the raw credential
Greptile/Veria P1: user_api_key_hash was the plaintext LITELLM_MASTER_KEY, which
fans out to spend logs and every callback (Langfuse/Datadog) and could be
recovered from logs. SHA-256 it (auth::hash_token, matching the proxy's
hash_token); the field is named *_hash and the proxy stores it verbatim when it
isn't sk-prefixed, so the DB value is identical with zero plaintext exposure.
* fix(litellm-rust): observe realtime logging on upstream events only
Greptile P1: observe ran on the client->upstream arm too, so an authenticated
client could send a fabricated response.done and inflate its own spend log.
session.created/response.done are server->client events; observe the upstream
arm only.
* feat(proxy): bound callback-logs batch + return per-record failures
Greptile P2: cap /v1/callbacks/logs at MAX_CALLBACK_LOG_RECORDS (default 1000,
env-overridable) so one POST can't trigger an unbounded callback/DB fan-out; and
return per-record {index, error} failures so a caller (the rust gateway) can
distinguish a transient callback error from a structurally bad payload.
* chore(ui): regenerate schema.d.ts for CallbackLogFailure / failures field
* fix(constants): make MAX_CALLBACK_LOG_RECORDS a plain constant
It doesn't need to be env-configurable (only the rust egress tunables are). As an
os.getenv var it tripped tests/documentation_tests/test_env_keys.py, which requires
every env key to be documented in the (separate-repo) config_settings.md. Plain
constant → not scanned → code-quality + documentation checks pass.
* docs(litellm-rust): trim ai-gateway ARCHITECTURE.md to one diagram + notes
* docs(litellm-rust): tighten the README request-logging section
* docs(litellm-rust): ARCHITECTURE.md is just the diagram (gateway = inference, spend = callback)
* docs(litellm-rust): drop em-dashes from the request-logging section
---------
Co-authored-by: Ishaan Jaffer <ishaanjaffer0324@gmail.com>
198 lines
8.7 KiB
Markdown
198 lines
8.7 KiB
Markdown
# LiteLLM Rust AI Gateway
|
||
|
||
A minimal Axum service that fronts OpenAI's realtime API. Clients open a
|
||
WebSocket to `GET /v1/realtime`; the gateway authenticates, selects a deployment,
|
||
dials OpenAI upstream, and splices the two sockets frame-by-frame.
|
||
|
||
## Crates
|
||
|
||
`litellm-rust` is exactly three crates (a crate is a **layer**, not a route):
|
||
|
||
| Crate | Role | Pure / I/O |
|
||
|-------|------|------------|
|
||
| litellm-core | Translation layer — types, route contracts (traits), provider transforms (modules under `providers/`), and the router. Builds requests/responses; no network. | Pure |
|
||
| litellm-ai-gateway | Routes + host — the only crate that touches the network. HTTP/WebSocket I/O (modules under `io/`) plus the Axum server binary (behind the `server` feature). | I/O |
|
||
| litellm-python-bridge | PyO3 cdylib exposing Rust to the litellm Python SDK — a thin adapter over litellm-ai-gateway's I/O. | Binding |
|
||
|
||
Dependency direction (acyclic): litellm-core ← litellm-ai-gateway ← litellm-python-bridge.
|
||
|
||
- **Client endpoint:** `wss://<host>/v1/realtime?model=<model>` (WebSocket)
|
||
- **Auth:** `Authorization: Bearer $LITELLM_MASTER_KEY` (fails closed if unset)
|
||
- **Health:** `GET /health/readiness`, `GET /health/liveness`, `GET /health/gil`
|
||
- **Request logs:** POSTed to a LiteLLM proxy at `/v1/rust_control_plane/logs` (see [Request logging](#request-logging))
|
||
|
||
> **Realtime serving is pure Rust.** Python is used at **load time only** — to
|
||
> read the config once at boot. The realtime hot path never touches Python.
|
||
|
||
## Configuration (config.yaml)
|
||
|
||
The gateway loads its `model_list` from a **config.yaml**, the same as the
|
||
LiteLLM proxy. Point `LITELLM_CONFIG_PATH` at the file:
|
||
|
||
```yaml
|
||
# config.yaml
|
||
model_list:
|
||
- model_name: gpt-realtime
|
||
litellm_params:
|
||
model: openai/gpt-realtime
|
||
api_key: os.environ/OPENAI_API_KEY
|
||
```
|
||
|
||
```bash
|
||
LITELLM_CONFIG_PATH=./config.yaml ./litellm-ai-gateway
|
||
```
|
||
|
||
At boot the gateway calls into `litellm.proxy.read_model_list`, which reuses the
|
||
**real proxy config reader** (`ProxyConfig.get_config`). That means everything
|
||
the proxy supports in config.yaml works here too:
|
||
|
||
- `include:` to merge in other config files,
|
||
- `os.environ/VAR` secret references (resolved via the secret manager, never
|
||
inlined),
|
||
- DB-stored models (when a database is configured).
|
||
|
||
Secrets stay out of the config — reference them with `os.environ/...` and set
|
||
the env var at deploy time. The shipped Docker image is built with the
|
||
`python-config` feature and **bundles litellm**, so config loading works out of
|
||
the box; the default baked config lives at `/app/config.yaml` and can be
|
||
overridden at deploy time (e.g. a Render secret file mounted at the same path).
|
||
|
||
### Environment variables
|
||
|
||
| Var | Required | Default | Purpose |
|
||
|---|---|---|---|
|
||
| `LITELLM_CONFIG_PATH` | yes (config mode) | — | Path to the config.yaml the gateway loads its `model_list` from. The Docker image defaults this to `/app/config.yaml`. |
|
||
| `LITELLM_MASTER_KEY` | yes | — | Bearer token clients must send. Unset ⇒ all `/v1/realtime` requests are rejected (fail closed). |
|
||
| `OPENAI_API_KEY` | yes | — | Upstream OpenAI key. Referenced by config.yaml as `os.environ/OPENAI_API_KEY` for the gateway→OpenAI dial. |
|
||
| `HOST` | no | `127.0.0.1` | **Set to `0.0.0.0` in any container/deploy** or external traffic is refused. |
|
||
| `PORT` | no | `4001` | Listen port. Render and most PaaS inject this automatically. |
|
||
| `LITELLM_PROXY_BASE_URL` | no | `http://localhost:4000` | LiteLLM proxy that request logs are POSTed to. See [Request logging](#request-logging). |
|
||
|
||
> Secrets (`LITELLM_MASTER_KEY`, `OPENAI_API_KEY`) are never baked into the image
|
||
> or `render.yaml` — inject them at deploy time only.
|
||
|
||
### Lean env stand-in (fallback)
|
||
|
||
If the binary is built **without** `python-config` (default features), or
|
||
`LITELLM_CONFIG_PATH` is unset, the gateway falls back to a single-deployment
|
||
stand-in built from the environment:
|
||
|
||
| Var | Default | Purpose |
|
||
|---|---|---|
|
||
| `OPENAI_REALTIME_MODEL` | `gpt-realtime` | The single deployment's model name (also the `?model=` clients pass). |
|
||
|
||
This mode links no libpython and needs no config file, but it only supports one
|
||
hard-coded OpenAI deployment. **config.yaml is the recommended path** — use the
|
||
stand-in only for the leanest possible build.
|
||
|
||
## Request logging
|
||
|
||
The gateway runs no spend logic. When a session ends it builds one
|
||
`StandardLoggingPayload` and POSTs it to `{LITELLM_PROXY_BASE_URL}/v1/rust_control_plane/logs`
|
||
(admin-only, bearer = `LITELLM_MASTER_KEY`), and the proxy replays it through its
|
||
normal callbacks (spend logs, Langfuse, etc.). The POST is non-blocking: a bounded
|
||
channel drained by a background worker, dropping with a counter if the proxy is
|
||
down. It sends one payload per session. Both env vars are in the table above.
|
||
|
||
Worker tuning, rarely needed: `LITELLM_LOG_CHANNEL_CAPACITY` (4096),
|
||
`LITELLM_LOG_BATCH_SIZE` (256), `LITELLM_LOG_FLUSH_INTERVAL_MS` (500).
|
||
|
||
## Build & run with Docker
|
||
|
||
The image is built `--features python-config` and installs litellm **from this
|
||
repo's source** (the config reader is newer than any PyPI release), so the build
|
||
**context is the repo root**:
|
||
|
||
```bash
|
||
# from the repo root
|
||
docker build -f litellm-rust/crates/ai-gateway/Dockerfile -t litellm-ai-gateway .
|
||
|
||
docker run --rm -p 4001:4001 \
|
||
-e HOST=0.0.0.0 -e PORT=4001 \
|
||
-e LITELLM_MASTER_KEY=sk-local \
|
||
-e OPENAI_API_KEY=$OPENAI_API_KEY \
|
||
litellm-ai-gateway # LITELLM_CONFIG_PATH defaults to /app/config.yaml
|
||
|
||
# smoke test
|
||
curl -s -o /dev/null -w '%{http_code}\n' localhost:4001/health/readiness # -> 200
|
||
curl -s -o /dev/null -w '%{http_code}\n' localhost:4001/v1/realtime # -> 401 (auth fails closed)
|
||
```
|
||
|
||
On boot you should see `loaded model_list from /app/config.yaml via python
|
||
config reader` — that confirms the config path (not the env stand-in fallback).
|
||
To use your own config, mount it over the default:
|
||
|
||
```bash
|
||
docker run --rm -p 4001:4001 \
|
||
-e HOST=0.0.0.0 -e LITELLM_MASTER_KEY=sk-local -e OPENAI_API_KEY=$OPENAI_API_KEY \
|
||
-v $(pwd)/my-config.yaml:/app/config.yaml:ro \
|
||
litellm-ai-gateway
|
||
```
|
||
|
||
### Cargo-only (no Docker)
|
||
|
||
```bash
|
||
# config.yaml mode — needs litellm importable in the active python env
|
||
LITELLM_CONFIG_PATH=./crates/ai-gateway/config.yaml \
|
||
cargo run --release -p litellm-ai-gateway --features python-config
|
||
|
||
# env stand-in mode — no python, no config
|
||
cargo run --release -p litellm-ai-gateway
|
||
```
|
||
|
||
## Deploy on Render
|
||
|
||
The service is a Docker **web service**; Render terminates TLS and supports
|
||
WebSockets, so the public endpoint is `wss://<service>.onrender.com/v1/realtime`.
|
||
|
||
### Option A — Blueprint (`render.yaml`)
|
||
|
||
`crates/ai-gateway/render.yaml` describes the service (Docker runtime,
|
||
`healthCheckPath: /health/readiness`, repo-root `dockerContext: .`,
|
||
`dockerfilePath: ./litellm-rust/crates/ai-gateway/Dockerfile`,
|
||
`LITELLM_CONFIG_PATH: /app/config.yaml`). `LITELLM_MASTER_KEY` and
|
||
`OPENAI_API_KEY` are `sync: false` — set them in the dashboard after the first
|
||
deploy. To use a non-default model_list, mount a **Render Secret File** at
|
||
`/app/config.yaml`. Point a Render Blueprint at this repo/branch and apply.
|
||
|
||
### Option B — Render API
|
||
|
||
```bash
|
||
# create a Docker web service from this repo+branch, then set env vars:
|
||
curl -X POST https://api.render.com/v1/services \
|
||
-H "Authorization: Bearer $RENDER_API_KEY" -H "Content-Type: application/json" \
|
||
-d '{
|
||
"type": "web_service", "name": "litellm-rust-ai-gateway",
|
||
"ownerId": "<owner-id>", "repo": "https://github.com/BerriAI/litellm",
|
||
"branch": "<branch-with-this-dockerfile>",
|
||
"serviceDetails": {
|
||
"env": "docker",
|
||
"envSpecificDetails": {
|
||
"dockerfilePath": "./litellm-rust/crates/ai-gateway/Dockerfile",
|
||
"dockerContext": "."
|
||
},
|
||
"healthCheckPath": "/health/readiness"
|
||
}
|
||
}'
|
||
# then set env vars LITELLM_MASTER_KEY, OPENAI_API_KEY, HOST=0.0.0.0,
|
||
# LITELLM_CONFIG_PATH=/app/config.yaml
|
||
```
|
||
|
||
Health check path **must** be `/health/readiness`. `autoDeploy` is off by default
|
||
in the blueprint — trigger deploys manually (or flip it on) to pick up new commits.
|
||
|
||
## Scaling
|
||
|
||
Concurrency is what matters, not total connections: each in-flight session holds
|
||
one client socket + one upstream socket. To scale, raise the instance count /
|
||
enable autoscaling on the Render service (e.g. baseline 10, max 100). Each
|
||
instance needs file descriptors for `2 × peak_concurrent_sessions` — raise
|
||
`ulimit -n` if you push very high concurrency.
|
||
|
||
## Latency note
|
||
|
||
The gateway adds the cost of one extra hop: client→gateway, then a fresh
|
||
gateway→OpenAI realtime handshake (TLS + WS upgrade + `session.created`). In
|
||
benchmarks this is ~100–150 ms of added session-establishment time; first-audio
|
||
and steady-state streaming add no measurable overhead. To minimize it, deploy the
|
||
gateway in the Render region with the lowest RTT to OpenAI's realtime endpoint.
|