Struct Agent 

pub struct Agent {
    pub messages: Vec<Message>,
    /* private fields */
}

Fields

messages: Vec<Message>

Implementations

impl Agent

pub fn new(client: ModelClient) -> Self

pub fn with_config(client: ModelClient, config: AgentConfig) -> Self

pub fn default(client: ModelClient) -> Self

pub fn set_steering_rx(&mut self, rx: UnboundedReceiver<String>)

Replace the steering receiver on a live agent. This is used by the TUI to attach a fresh channel before each send() call so that mid-turn steering can be injected.

pub async fn send(&mut self, prompt: &str) -> Result<String>

pub async fn send_with_goal( &mut self, prompt: &str, goal_pause_rx: Option<&mut UnboundedReceiver<String>>, ) -> Result<String>

Goal-aware wrapper around send(). After the initial turn completes, the agent checks the persistent goal store. If the goal is still Active, it injects a continuation prompt as a system message (steering, not user input — matching Codex’s continuation_steering_item) and starts another send() turn internally.

The TUI sees the agent running longer and receives GoalContinuation / GoalTurnAccounted / GoalErrorTransition events for display and accounting.

goal_pause_rx is an optional receiver that the TUI can use to signal a deferred pause or clear. Values: “pause” or “clear”.

pub fn last_send_usage(&self) -> &Usage

Returns the cumulative token usage from the most recent send() call. This is the sum of usage across all model iterations within that call.

pub fn set_event_sink(&mut self, sink: EventSink)

pub fn restore_messages(&mut self, messages: Vec<Message>)

pub fn lean_resume(&mut self) -> Result<()>

Crash-recovery method: flush working memory down to the initial system messages and bootstrap a lean context from externalized state in SQLite.

After calling this the orchestrator retains its system prompt, agents.md, and skills catalog messages, plus a single synthetic system message that summarises the active goal, threads, and worksets so it can resume work without re-reading the full conversation history.

pub fn terminal_manager(&self) -> &TerminalManager