Struct Runtime 

pub struct Runtime {
    pub config: ConfigToml,
    pub model_registry: ModelRegistry,
    pub thread_manager: ThreadManager,
    pub tool_registry: Arc<ToolRegistry>,
    pub mcp_manager: Arc<McpManager>,
    pub exec_policy: ExecPolicyEngine,
    pub hooks: HookDispatcher,
    pub jobs: JobManager,
}

Top-level runtime combining config, model registry, threads, tools, MCP, and hooks.

Fields

config: ConfigToml

Resolved application configuration.

model_registry: ModelRegistry

Registry of available model providers.

thread_manager: ThreadManager

Manages conversation thread lifecycle.

tool_registry: Arc<ToolRegistry>

Registry of callable tools.

mcp_manager: Arc<McpManager>

Manager for MCP server connections.

exec_policy: ExecPolicyEngine

Engine for evaluating execution policy decisions.

hooks: HookDispatcher

Dispatcher for lifecycle hooks.

jobs: JobManager

Manager for background job lifecycle.

Implementations

impl Runtime

pub fn new( config: ConfigToml, model_registry: ModelRegistry, state: StateStore, tool_registry: Arc<ToolRegistry>, mcp_manager: Arc<McpManager>, exec_policy: ExecPolicyEngine, hooks: HookDispatcher, ) -> Self

Constructs a new Runtime, loading existing jobs from the state store.

pub async fn handle_thread( &mut self, req: ThreadRequest, ) -> Result<ThreadResponse>

Dispatches a thread request (create, start, resume, fork, list, read, etc.).

pub async fn handle_prompt( &mut self, req: PromptRequest, cli_overrides: &CliRuntimeOverrides, ) -> Result<PromptResponse>

Resolves the model for a prompt, records the message, and returns the response.

pub async fn invoke_tool( &self, call: ToolCall, approval_mode: AskForApproval, cwd: &Path, ) -> Result<Value>

Evaluates execution policy and dispatches a tool call.

pub async fn mcp_startup(&self) -> McpStartupCompleteEvent

Starts all configured MCP servers and emits startup events via hooks.

pub fn app_status(&self) -> AppResponse

Returns the current application status including all jobs and their history.

pub fn provider_default(&self) -> ProviderKind

Returns the default model provider from the resolved configuration.

pub fn save_thread_checkpoint( &self, thread_id: &str, checkpoint_id: &str, state: &Value, ) -> Result<()>

Saves a named checkpoint for a thread.

pub fn load_thread_checkpoint( &self, thread_id: &str, checkpoint_id: Option<&str>, ) -> Result<Option<Value>>

Loads a checkpoint for a thread. Pass None for the latest.

pub fn enqueue_job(&mut self, name: impl Into<String>) -> Result<JobRecord>

Enqueues a new background job and persists it immediately.

pub fn set_job_running(&mut self, job_id: &str) -> Result<()>

Transitions a job to running and persists the change.

pub fn update_job_progress( &mut self, job_id: &str, progress: u8, detail: Option<String>, ) -> Result<()>

Updates a job’s progress and persists the change.

pub fn complete_job(&mut self, job_id: &str) -> Result<()>

Marks a job as completed and persists the change.

pub fn fail_job( &mut self, job_id: &str, detail: impl Into<String>, ) -> Result<()>

Marks a job as failed and persists the change.

pub fn cancel_job(&mut self, job_id: &str) -> Result<()>

Cancels a job and persists the change.

pub fn pause_job(&mut self, job_id: &str, detail: Option<String>) -> Result<()>

Pauses a job and persists the change.

pub fn resume_job(&mut self, job_id: &str, detail: Option<String>) -> Result<()>

Resumes a paused job and persists the change.

pub fn job_history(&self, job_id: &str) -> Vec<JobHistoryEntry>

Returns the state-transition history for a job.