Push a request onto the queue with the given priority. # Arguments `priority` — Relative importance; see [`Priority`]. `request` — The [`PromptReque

Get cached value if exists and not expired # Panics This function does not panic.

Get current queue size

Push a dropped request into the queue. Evicts the oldest entry if full. # Panics This function does not panic. If the internal mutex is poisoned it

Register a plugin by its manifest. # Errors - [`PluginError::PluginAlreadyRegistered`] if the ID already exists. - [`PluginError::InvalidManifest`] i

Spawn the complete 5-stage pipeline Returns handles to all tasks and the input sender. Caller should send PromptRequests to input_tx and await handle

Updates the app state with one tick of mock data. # Arguments `app` - Mutable reference to the app state to update.

Record a new feedback entry. The entry's score is clamped to `[0.0, 1.0]` before storage. If the collector is at capacity, the oldest entry is evicte

Create and store a new configuration snapshot. The version number is auto-incremented. If the store is at capacity, the oldest snapshot is evicted be

Retrieve a snapshot by its version number. # Arguments `version` - The version number to look up. # Returns A clone of the matching [`ConfigSnapsh

Helper: build a parameter map from slice of pairs.

Atomically claim the next available task by priority. Writes a lock file `{lock_dir}/{task_id}.claimed` with the agent ID. If a lock file already exi

Advances the mock story by one tick (1 second). Updates all state fields based on the current story phase. # Panics This function never panics.

Execute a fallible async operation through the circuit breaker. If the circuit is `Open` the operation is **not called** and `Err(CircuitBreakerError

Return the number of entries currently in the queue. # Panics This function does not panic. If the internal mutex is poisoned it is recovered automa

Spawn a web API server in the background and return its base URL plus the pipeline receiver so tests can verify forwarded requests.

Check if queue is empty

Ingest a single metric value, run all enabled detectors, and return any anomalies found. The value is appended to the metric's rolling window (bounde

Return `true` if the queue contains no entries. # Panics This function does not panic. If the internal mutex is poisoned it is recovered automatical

Record a cost entry from a completed inference request. If the number of entries exceeds `max_entries`, the oldest entry is removed to maintain bound

Atomically check whether a request is new, in-progress, or cached, and register it as in-progress if it is new. Uses `DashMap::entry()` for a compare

Initialise all Prometheus metrics and register them with a private registry. Must be called once at process startup before any pipeline stage is spaw

Route a prompt to the appropriate worker. # Arguments `prompt` — The raw prompt text to analyse and route. # Returns A [`RoutingDecision`] indicat

Set cached value with TTL in seconds # Panics This function does not panic.

Applies an input event to the app state. # Arguments `app` - Mutable reference to app state. `event` - The input event to apply.

Helper to build a valid config that can be mutated for negative tests.

Set server URL

Return a snapshot of the loop's current counters.

Return a reference to the initialised [`Metrics`], or `None` if [`init_metrics`] has not been called yet.

Register a model for routing. Duplicate registrations are idempotent. # Errors Returns [`RouterError::LockPoisoned`] if the internal lock is poisone

Create a new deployment in `Pending` stage. # Arguments `id` — Unique identifier for the deployment `description` — Human-readable description of the

Register a model name with the learned router. Must be called for every model that can be selected. Duplicate registrations are idempotent. # Argume

Pushes a log entry, evicting the oldest if at capacity.

Force an immediate snapshot collection and broadcast (useful in tests).

Mark a request as successfully completed and cache its result. Notifies all tasks currently blocked in [`Deduplicator::wait_for_result`] for the same

Insert a new modification record.

Create a test [`DashboardState`] backed by an echo worker pipeline (live mode).

Create a new [`OrchestratorMcp`] server instance. Spawns a background collector task that reads completed pipeline outputs and dispatches them to the

Drive the self-improvement loop until `shutdown_rx` is set to `true`. ## Production guard If `RUST_ENV=production` is set, this method logs a warning

Validate all semantic constraints on a [`PipelineConfig`]. Collects every violation before returning so the caller sees the full scope of issues at o

Register a node in the cluster topology. If the node already exists, updates its heartbeat and load. # Arguments `node_id` — Node identifier `addres

Get cache statistics # Panics This function does not panic.

Increment the error counter for a pipeline stage and error type. No-op if metrics have not been initialised. # Panics This function never panics.

Get a snapshot of all tasks and their current statuses. # Panics This function never panics.

Provide a breakdown of individual signal contributions. Useful for debugging, logging, and transparency into routing decisions. # Arguments `prompt

Deterministic dedup key from prompt content (mirrors `enhanced::dedup::dedup_key`).

Parses Prometheus text format into app state.

Inject an external pressure signal (e.g. from HelixRouter's `pressure_score`). `pressure` is clamped to `[0.0, 1.0]`. This value is blended with the

Return a snapshot of current cost metrics. # Returns A [`CostSnapshot`] with all current counters and computed costs. # Panics This function never

Borrow the inner string slice. # Panics This function does not panic.

Analyse a telemetry snapshot and generate tasks for any triggered thresholds. Rate-limiting is respected - templates on cooldown are skipped.

Submit a new proposal to change a parameter. # Errors - [`BrainError::MaxProposalsReached`] if too many proposals are pending. - [`BrainError::LockPo

Record tokens processed by the local worker. # Arguments `tokens` — Number of tokens processed. # Panics This function never panics.

Return a point-in-time snapshot of all current values. # Panics This function never panics.

Evaluate all gates for a change proposal. In the current implementation this runs the checks in-process where possible and spawns child processes for

Randomly initialise the population within configured parameter bounds. # Errors Returns [`SearchError::LockPoisoned`] if the internal lock is poisone

Record the outcome of a completed inference call. This is the primary feedback path: it estimates response quality, injects a `FeedbackEntry`, and im

Return a snapshot of the current population. # Panics This function never panics.

Record the processing latency for a pipeline stage. No-op if metrics have not been initialised. # Panics This function never panics.

Register an agent as healthy. # Arguments `agent_id` - The agent to register # Panics This function never panics.

Set temperature (0.0 – 2.0 for OpenAI). Values outside `[0.0, 2.0]` are clamped and a `WARN`-level log line is emitted. The OpenAI API rejects value

Increment the request counter for a pipeline stage. No-op if metrics have not been initialised. # Panics This function never panics.

Remove and return the highest-priority request. Among requests with equal priority the one inserted first is returned (FIFO within a tier). # Return

Return a count summary of stored records.

Set maximum tokens to generate

Advance a rolling deployment to the next rollout step. Checks current metrics against baseline: - If any metric whose key contains `"error_rate"` exc

Compute the current budget status including spend totals, projections, per-model breakdowns, and the current alert level. # Returns A `BudgetStatus`