Struct Agent 

pub struct Agent<P: Provider + 'static> {
    pub config: AgentConfig,
    /* private fields */
}

An immutable agent definition.

Generic over P: crabllm_core::Provider — holds a Model<P> wrapper alongside config, tool schemas, and an optional sender for tool dispatch. Conversation history is owned externally and passed into execution methods. 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<P: Provider + 'static> Agent<P>

pub async fn compact(&self, history: &[HistoryEntry]) -> Option<String>

Summarize the conversation history using the LLM.

Builds the base compact prompt, lets the compact_hook (if any) enrich it, then sends the history with the enriched prompt as system message. Returns the summary text, or None if the model produces no content.

impl<P: Provider + 'static> Agent<P>

pub async fn step( &self, history: &mut Vec<HistoryEntry>, conversation_id: Option<u64>, ) -> Result<AgentStep>

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

Composes a ChatCompletionRequest from config state (system prompt + history + tool schemas), calls the stored model, dispatches any tool calls via the ToolDispatcher, and appends results to history.

pub async fn run( &self, history: &mut Vec<HistoryEntry>, events: UnboundedSender<AgentEvent>, conversation_id: Option<u64>, tool_choice: Option<ToolChoice>, ) -> 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.

pub fn run_stream<'a>( &'a self, history: &'a mut Vec<HistoryEntry>, conversation_id: Option<u64>, steer_rx: Option<Receiver<Option<String>>>, tool_choice: Option<ToolChoice>, ) -> impl Stream<Item = AgentEvent> + 'a

Run the agent loop as a stream of AgentEvents.

Uses the model’s streaming API so text deltas are yielded token-by-token. Tool call responses are dispatched after the stream completes (arguments arrive incrementally and must be fully accumulated first).

Trait Implementations

impl<P: Provider + 'static> Clone for Agent<P>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.