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).

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 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 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>>