Struct DefaultAgentRuntime 

pub struct DefaultAgentRuntime {
    pub llm: Arc<dyn LlmPort>,
    pub tools: Arc<dyn ToolPort>,
    pub store: Arc<dyn SessionStore>,
    pub events: Arc<dyn EventSink>,
    pub default_model: String,
    pub policy: TurnPolicy,
    pub tool_policy: Arc<dyn ToolPolicyPort>,
    pub approval: Arc<dyn ApprovalPort>,
    pub dispatch_mode: DispatchMode,
    pub checkpoint_store: Arc<dyn TurnCheckpointStorePort>,
    pub artifact_store: Arc<dyn ArtifactStorePort>,
    pub cost_meter: Arc<dyn CostMeterPort>,
}

Default runtime that composes the 4 port traits via Arc<dyn ...>.

Fields

llm: Arc<dyn LlmPort>

tools: Arc<dyn ToolPort>

store: Arc<dyn SessionStore>

events: Arc<dyn EventSink>

default_model: String

policy: TurnPolicy

tool_policy: Arc<dyn ToolPolicyPort>

approval: Arc<dyn ApprovalPort>

dispatch_mode: DispatchMode

checkpoint_store: Arc<dyn TurnCheckpointStorePort>

artifact_store: Arc<dyn ArtifactStorePort>

cost_meter: Arc<dyn CostMeterPort>

Trait Implementations

impl AgentRuntime for DefaultAgentRuntime

fn run<'life0, 'async_trait>( &'life0 self, req: AgentRequest, ) -> Pin<Box<dyn Future<Output = Result<AgentRunResult, AgentError>> + Send + 'async_trait>>

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

Execute a single agent turn (blocking until complete).

fn run_stream<'life0, 'async_trait>( &'life0 self, req: AgentRequest, ) -> Pin<Box<dyn Future<Output = Result<AgentEventStream, AgentError>> + Send + 'async_trait>>

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

Execute a single agent turn with streaming events.

fn health<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = RuntimeHealth> + Send + 'async_trait>>

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

Check runtime health.

impl Debug for DefaultAgentRuntime

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.