Struct InProcessRuntime 

pub struct InProcessRuntime { /* private fields */ }

Public in-process runtime backed by either in-memory or custom stores.

This runtime is intended for embedders who want to execute Everruns harnesses inside their own process while controlling capabilities, harness definitions, and driver registrations directly in Rust.

Implementations

impl InProcessRuntime

pub fn builder() -> InProcessRuntimeBuilder

Create a builder for the in-process runtime.

pub fn default_session_id(&self) -> Option<SessionId>

Return the default session id seeded by InProcessRuntimeBuilder::single_session, if one was configured.

pub async fn run_turn( &self, session_id: SessionId, input: impl Into<InputMessage>, ) -> Result<TurnResult>

Execute one turn for an existing session.

The input message is stored in the runtime history, an input.message event is emitted, and the turn then executes the shared core input -> reason -> act state machine.

pub async fn run_text_turn( &self, session_id: SessionId, text: impl Into<String>, ) -> Result<TurnResult>

pub async fn messages(&self, session_id: SessionId) -> Result<Vec<Message>>

Load the current message history for a session.

pub async fn read_file( &self, session_id: SessionId, path: &str, ) -> Result<Option<SessionFile>>

Read a file from the in-memory session filesystem.

pub async fn load_context( &self, session_id: SessionId, ) -> Result<AssembledTurnContext>

Assemble the current runtime context for a session without executing a turn.

pub async fn events(&self) -> Result<Vec<Event>>

Return all collected events from the runtime event bus.

Event buses that do not retain events return an empty Vec (see EventBus::collected_events).

pub async fn execute_command( &self, session_id: SessionId, request: ExecuteCommandRequest, ) -> Result<CommandResult>

Execute a system command declared by a registered capability.

Looks up the first capability whose commands() includes the named command (in capability-resolution order) and delegates to its execute_command. Returns an error if no capability declares the requested name. The coding-CLI example uses this for /model (provided by ModelSwitcherCapability) so the dispatch path stays inside the capability instead of the TUI’s local handle_command branches.

pub async fn list_commands( &self, session_id: SessionId, ) -> Result<Vec<CommandDescriptor>>

List slash commands available for a session.

Resolves the session’s harness/agent capability chain and aggregates commands declared via Capability::commands, deduplicated by name (first occurrence wins, matching the order of resolved capabilities). This is the embedded equivalent of the server’s GET /v1/sessions/{id}/commands system-commands list — skill commands are not included here because skills are discovered via the platform filesystem rather than the capability registry.

Trait Implementations

impl Clone for InProcessRuntime

fn clone(&self) -> InProcessRuntime

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl RuntimeHostAdapter for InProcessRuntime

fn get_agent<'life0, 'async_trait>( &'life0 self, _org_id: i64, agent_id: AgentId, ) -> Pin<Box<dyn Future<Output = Result<Option<Agent>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_harness<'life0, 'async_trait>( &'life0 self, _org_id: i64, harness_id: HarnessId, ) -> Pin<Box<dyn Future<Output = Result<Option<Harness>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn set_session_status<'life0, 'async_trait>( &'life0 self, _org_id: i64, session_id: SessionId, _status: SessionStatus, ) -> Pin<Box<dyn Future<Output = Result<Session>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn load_turn_context<'life0, 'async_trait>( &'life0 self, _org_id: i64, session_id: SessionId, ) -> Pin<Box<dyn Future<Output = Result<RuntimeHostTurnContext>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn mcp_executor<'life0, 'async_trait>( &'life0 self, _org_id: i64, session_id: SessionId, ) -> Pin<Box<dyn Future<Output = Option<Arc<McpExecutor>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

MCP executor routing mcp_* tool calls for this session, if the host configures MCP (specs/runtime-mcp.md D4). Default: None, so hosts without scoped MCP servers keep the plain tool registry unchanged.

fn capability_registry(&self) -> CapabilityRegistry

fn driver_registry(&self) -> DriverRegistry

fn harness_store(&self, _org_id: i64) -> Arc<dyn HarnessStore>

fn agent_store(&self, _org_id: i64) -> Arc<dyn AgentStore>

fn session_store(&self, _org_id: i64) -> Arc<dyn SessionStore>

fn session_mutator(&self, _org_id: i64) -> Arc<dyn SessionMutator>

fn provider_store(&self, _org_id: i64) -> Arc<dyn LlmProviderStore>

fn message_store(&self) -> Arc<dyn MessageRetriever>

fn event_emitter(&self) -> Arc<dyn EventEmitter>

fn file_store(&self) -> Arc<dyn SessionFileSystem>

fn storage_store(&self) -> Option<Arc<dyn SessionStorageStore>>

fn utility_llm_service(&self) -> Option<Arc<dyn UtilityLlmService>>

fn egress_service(&self) -> Option<Arc<dyn EgressService>>

fn memory_store(&self, _org_id: i64) -> Option<Arc<dyn MemoryStoreBackend>>

fn image_resolver(&self, _org_id: i64) -> Option<Arc<dyn ImageResolver>>

fn image_artifact_store( &self, _org_id: i64, ) -> Option<Arc<dyn ImageArtifactStore>>

fn provider_credential_store( &self, _org_id: i64, ) -> Option<Arc<dyn ProviderCredentialStore>>

fn connection_resolver(&self) -> Option<Arc<dyn UserConnectionResolver>>

fn sqldb_store(&self) -> Option<SessionSqlDbStoreRef>

fn leased_resource_store(&self) -> Option<Arc<dyn LeasedResourceStore>>

fn session_resource_registry(&self) -> Option<Arc<dyn SessionResourceRegistry>>

fn schedule_store(&self, _org_id: i64) -> Option<Arc<dyn SessionScheduleStore>>

fn platform_store( &self, _org_id: i64, _session_id: SessionId, ) -> Option<Arc<dyn PlatformStore>>

fn budget_checker( &self, _org_id: i64, _agent_id: Option<AgentId>, ) -> Option<Arc<dyn BudgetChecker>>

fn payment_authority( &self, _org_id: i64, _agent_id: Option<AgentId>, ) -> Option<Arc<dyn PaymentAuthority>>

fn outbound_tool_rate_limiter( &self, _org_id: i64, ) -> Option<Arc<dyn OutboundToolRateLimiter>>

Per-org outbound tool-call rate limiter (TM-TOOL-009). Default: None (no rate limiting — suitable for in-process / test environments).