Struct AgentLoopHarness 

pub struct AgentLoopHarness<M, R> { /* private fields */ }

Implementations

impl<M, R: ToolRuntime> AgentLoopHarness<M, R>

pub fn new(model: M, tools: R) -> Self

pub fn with_max_steps(self, max_steps: usize) -> Self

Cap the number of LLM steps per turn. 0 means unlimited — the loop only ends when the model stops calling tools (or on cancel/error), so callers passing 0 should keep their own liveness backstop (idle/wall-clock) around the turn.

pub fn with_compaction(self, policy: CompactionPolicy) -> Self

Attach a compaction policy. The loop will call policy.strategy.should_compact before every step and run policy.strategy.compact when it fires. Without a policy installed the loop never compacts — fine for short / test conversations, fatal for long production sessions.

pub fn with_tool_choice(self, choice: ToolChoice) -> Self

Constrain how the model selects tools this turn. Defaults to Auto. See ToolChoice for variants.

pub fn with_parallel_tool_calls(self, parallel: Option<bool>) -> Self

OpenAI-only: whether the model may emit multiple tool_use blocks in one response. None ⇒ provider default (true on OpenAI). Ignored by Anthropic (multi tool_use is implicit).

pub fn with_stream_resilience( self, idle_timeout: Duration, max_attempts: u32, ) -> Self

Override mid-stream resilience knobs. idle_timeout is how long a step waits for the next model chunk before declaring a stall; max_attempts is the stream-layer reconnect budget (total stream attempts, so max_attempts = 1 disables reconnection). Primarily for tests, which inject a sub-second timeout so a stall surfaces fast instead of after the 90s production default.

Trait Implementations

impl<M: Clone, R: Clone> Clone for AgentLoopHarness<M, R>

fn clone(&self) -> AgentLoopHarness<M, R>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<M, R> NativeHarness for AgentLoopHarness<M, R>

where M: ModelClient + Clone + Send + Sync + 'static, R: ToolRuntime + Clone + Send + Sync + 'static,

fn run_turn<'life0, 'async_trait>( &'life0 self, input: NativeTurnInput, ) -> Pin<Box<dyn Future<Output = Result<Receiver<Result<HarnessInternalEvent, NativeHarnessError>>, NativeHarnessError>> + Send + 'async_trait>>

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