Struct Agent 

pub struct Agent<M: Model> {
    pub config: AgentConfig,
    /* private fields */
}

A stateful agent execution unit.

Generic over M: Model — stores the model provider alongside config and conversation history. Callers drive execution via step() (single LLM round), run() (loop to completion), or run_stream() (yields events as a stream).

Fields

config: AgentConfig

Agent configuration (name, prompt, model, limits, tool_choice).

Implementations

impl<M: Model> Agent<M>

pub fn push_message(&mut self, message: Message)

Push a message into the conversation history.

pub fn messages(&self) -> &[Message]

Return a reference to the conversation history.

pub fn clear_history(&mut self)

Clear the conversation history, keeping configuration intact.

pub async fn step<D: Dispatcher>(&mut self, dispatcher: &D) -> Result<AgentStep>

Perform a single LLM round: send request, dispatch tools, return step.

Composes a Request from config state (system prompt + history + dispatcher tools), calls the stored model, dispatches any tool calls via dispatcher.dispatch(), and appends results to history.

pub async fn run<D: Dispatcher>( &mut self, dispatcher: &D, events: UnboundedSender<AgentEvent>, ) -> AgentResponse

Run the agent loop to completion, returning the final response.

Wraps Agent::run_stream — collects all events, sends each through events, and extracts the Done response. The event sender allows callers (like Runtime) to observe execution without reimplementing the step loop.

pub fn run_stream<'a, D: Dispatcher + 'a>( &'a mut self, dispatcher: &'a D, ) -> impl Stream<Item = AgentEvent> + 'a

Run the agent loop as a stream of AgentEvents.

The canonical step loop. Calls Agent::step up to max_iterations times, yielding events as they are produced. Always finishes with a Done event containing the AgentResponse.