Struct AgentLoop 

pub struct AgentLoop { /* private fields */ }

AgentLoop.

Implementations

impl AgentLoop

pub fn new_with_resolver( provider: Arc<dyn Provider>, config: AgentLoopConfig, tools: Arc<ToolRegistry>, state: SharedState, resolver: Arc<dyn ProviderResolver>, ) -> Self

TODO. Create a new AgentLoop with an explicit resolver.

pub fn new( provider: Arc<dyn Provider>, config: AgentLoopConfig, tools: Arc<ToolRegistry>, state: SharedState, ) -> Self

Create a new AgentLoop using the global resolver (backward compat).

pub fn with_before_tool_call(self, hook: BeforeToolCallHook) -> Self

TODO: document this function.

pub fn with_after_tool_call(self, hook: AfterToolCallHook) -> Self

TODO: document this function.

pub fn steer(&self, message: Message)

TODO: document this function.

pub fn follow_up(&self, message: Message)

TODO: document this function.

pub fn clear_steering_queue(&self)

TODO: document this function.

pub fn clear_follow_up_queue(&self)

TODO: document this function.

pub fn clear_all_queues(&self)

TODO: document this function.

pub fn cancel_auto_retry(&self)

TODO: document this function.

pub fn auto_retry_attempt(&self) -> usize

TODO: document this function.

pub fn state(&self) -> &SharedState

Get a reference to the shared state. Used by Agent to sync state after loop execution.

pub fn external_stop(&self) -> &Arc<AtomicBool>

Get the external stop flag.

pub async fn run( &self, prompt: String, emit: impl Fn(AgentEvent) + Send + Sync + 'static, ) -> Result<Vec<AgentEvent>>

TODO: document this function.

pub async fn run_messages( &self, prompts: Vec<Message>, emit: Arc<dyn Fn(AgentEvent) + Send + Sync>, ) -> Result<Vec<AgentEvent>>

TODO: document this function.

pub async fn continue_loop( &self, emit: impl Fn(AgentEvent) + Send + Sync + 'static, ) -> Result<Vec<AgentEvent>>

TODO: document this function.