Struct InProcessHost 

pub struct InProcessHost { /* private fields */ }

In-process host: nested TurnRuntime with shared sampler, tool pool, and limits.

Implementations

impl InProcessHost

pub fn new(sampler: Arc<dyn LlmSampler>, tools: Vec<SharedTool>) -> Self

Create a host with default depth/concurrency caps and unlimited agent budget.

pub const fn with_agent_budget(self, budget: u64) -> Self

Absolute agent-call budget for this host (every successful admission counts 1).

pub const fn with_max_spawn_depth(self, max: Option<u32>) -> Self

Cap nesting depth (depth must be < max). None disables the limit.

pub fn with_max_concurrent_children(self, max: Option<usize>) -> Self

Cap concurrent in-flight children. None disables the limit.

pub fn with_agent_registry(self, registry: AgentRegistry) -> Self

Install a full agent registry for agent_type resolution.

pub fn with_agent_definitions( self, defs: impl IntoIterator<Item = AgentDefinition>, ) -> Self

Register agent definitions (merged into the host registry).

pub fn with_prompt_assembler(self, assembler: Arc<dyn PromptAssembler>) -> Self

Install a prompt assembler applied when resolving agent_type definitions.

pub fn with_isolation(self, isolation: Arc<dyn IsolationBackend>) -> Self

Install an isolation backend (default InProcessIsolation).

pub fn with_metrics(self, metrics: SharedMetrics) -> Self

Metrics sink for spawn/turn accounting.

pub fn with_parent_handle(self, handle: ChatStateHandle) -> Self

Parent conversation handle used when fork_context is set without messages.

pub fn with_run_store(self, store: Arc<dyn WorkflowRunStore>) -> Self

Workflow run store enabling resume_from on spawn opts.

pub fn with_instructions(self, instructions: impl Into<String>) -> Self

Override child system instructions (used when agent_type is unset).

pub fn agent_registry(&self) -> &AgentRegistry

Shared agent registry (clone is cheap).

pub fn agents_spent(&self) -> u64

Agents admitted so far (including in-flight after reservation).

pub fn agents_remaining(&self) -> Option<u64>

Remaining budget when capped.

pub const fn max_spawn_depth(&self) -> Option<u32>

Configured max spawn depth.

pub const fn max_concurrent_children(&self) -> Option<usize>

Configured max concurrent children.

Trait Implementations

impl Debug for InProcessHost

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

Formats the value using the given formatter.

impl SessionHost for InProcessHost

fn spawn_agent<'life0, 'async_trait>( &'life0 self, opts: SpawnOpts, ) -> Pin<Box<dyn Future<Output = Result<AgentRunResult, MachiError>> + Send + 'async_trait>>

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

Spawn and run a nested agent to completion.

fn spawn_agents<'life0, 'async_trait>( &'life0 self, opts: Vec<SpawnOpts>, ) -> Pin<Box<dyn Future<Output = Result<Vec<AgentRunResult>, MachiError>> + Send + 'async_trait>>

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

Spawn many nested agents concurrently (order of results matches input).