EFFICIENT default. CAPABLE only when the scorer is confidently positive.

Records one LLM-classifier overhead call. The classifier's per-request call is not part of the routed-backend chain and must stay out of `by_model` —

Replaces the selected target, returning the previous target.

Hand `target` this prompt on every turn it serves.

Normalize an object to an owned JSON value.

Build an OpenAI SDK client pointed at the passthrough server. The passthrough server injects its own upstream ``api_key`` into calls it makes

Build an OpenAI SDK client pointed at the passthrough server. Same convention as the Chat Completions sibling — the passthrough injects its o

Returns the stable string identifier for a built-in format.

Build this config into a concrete profile runtime.

The whole decode → call → encode path a wire endpoint needs, in one call. Decodes `raw_http_request` from `wire_format` to the neutral IR, serves it

Match `text` against the error pattern table. Returns `(max_severity, matched_pattern_names)`.

Claude Code / Codex / Cursor traffic; SIMPLE+MEDIUM→weak. Routine turns inside an agentic session (single-line edits, file exploratio

Terminate the stream with an error item — the producer-side way to surface a failure to the consumer (mirrors how the crate's `run_stream` yields an `

Reads the request's `model` field when present and string-valued.

Build a shared `TestAlgo` over the given target set.

Replace the body without changing its wire format.

Returns the request's tagged wire format.

A `State` carrying `signal` as its tool signals.

Overrides the packaged classifier prompt.

Anthropic request whose trailing user turn carries a tool_result block.

Call the logger and return the single emitted record parsed as JSON.

Recorded route selection, with *overrides* applied.

Apply benchmark-specific DeepSeek extras without clobbering callers.

Async wrapper for the OpenAI Responses API. When a non-blank ``api_key`` is supplied, the call uses that per-request credential via t

Build a Rust ``MultiLlmBackend`` from configured targets.

Build a Rust ``LlmTarget`` from a target object or legacy mapping.

Decodes one provider event while retaining its parsed source JSON value. Takes ownership of `event` so preservation does not deep-copy provider JSON

Creates a fake backend that returns one error.

Handle an unexpected chain exception: check for upstream status, log, and return envelope.

Returns a header value using case-insensitive matching.

Returns the actual bound address, including an OS-selected port.

Return registered model ids in registration order.

Response headers for the route selection recorded on *ctx*, if any. Empty when no routing backend recorded a selection (passthrough chains, f

Start the child and block until it exits. Returns its exit code.

Process a request to completion, returning a stream of [`Step`]s. The consumer must fulfill every [`Step::CallLlm`] before the algorithm can continue

Scores through the definitive classification variant used by affinity.

Serialize a chain result to the appropriate HTTP response. Returns the result itself if it is already a ``Response``, wraps it in a ``Streami

The tests in this file must not overlap because metrics are global. There is no Rust/cargo-native way of saying this (people use `serial_test` crate)

Set the request model, replacing a malformed non-object body.

Return *base_url* with a trailing ``/v1`` path component removed. Switchyard's ``--base-url`` convention follows OpenAI's (e.g. ``https://ope

`(name, has_client)` — `has_client: false` builds a target with no default client.

Patch ``uvicorn.run`` to capture its kwargs without starting a server.

Build a minimal OpenAI-shaped streaming chunk.

Build a MagicMock that quacks like ``ChatCompletion``.

Build the argparse namespace ``build_and_serve`` expects.

Config mapping COMPLEX/REASONING→strong, SIMPLE/MEDIUM/default→weak.

Build a table of passthrough chains for *tiers* and their catalogs. For each tier this: 1. Registers the tier's configured model as a direct

Offload a call to `target`: pair `request` with `decision` and the target's default client into a [`RoutedRequest`], then publish it (see [`call_llm`]

Gracefully stop the native server.

Shared HTTP config, regardless of variant.

Return the advertised default model id, falling back to first entry.

Embeds preservation metadata into a translated wire body when requested.

Build a JSONResponse with Switchyard's normalized error envelope. Stamps the failure-source headers: every direct caller synthesizes a Switch