Register a tool by ID.

Insert one pinned agent and its immutable version metadata.

Execute the agent loop. Prefer `AgentRuntime::run()` for production use. Handles both fresh runs and resumed runs (state-driven detection). Supports

Signal background tasks to shut down.

Borrow the thread/run store for read paths. Writes must be routed through `mailbox.coordinator()`.

Render Prometheus text exposition format. Returns `None` if the recorder has not been installed.

Returns `true` when no lineage fields are set.

Returns the number of messages currently buffered in the channel.

Take all collected events, leaving the buffer empty.

Send a message to the owner agent. Returns `true` if delivered to the channel. Returns `false` if the receiver was dropped — in that case `on_closed`

Get the summary of a specific task.

Extract concatenated text parts.

Parse a service-account JSON string. Validates the minimum fields the signer needs (`client_email`, `private_key`, with `private_key` looking like a P

Spawn a background task. `name` is an optional short identifier for addressing (e.g. "researcher"). If provided, it must be unique among running task

Number of frames currently in the buffer.

Create a new thread with a specific identifier.

Register an agent spec.

Register a provider (LLM executor) by ID.

Ensure all tables exist. Called lazily on first access.

Run one scene; never throws — records outcome and keeps the camera rolling.

Write a typed value.

Returns the current time in milliseconds since the UNIX epoch. Uses `unwrap_or_default()` so the call never panics (returns `0` if the system clock i

Build the complete router for the given state.

Register a model offering. The id is extracted from `spec.id`.

Parse a pattern string into a [`ToolCallPattern`].

Return a cloned `Arc` of the agent resolver.

Abort lifecycle tasks. This is idempotent.