Struct AgentAdvisor 

pub struct AgentAdvisor { /* private fields */ }

Unstable (feature: advisor) — may change or be removed

An [`AdvisorAgent`] backed by a concrete [`Agent`].

Implementations

impl AgentAdvisor

pub fn new(agent: Arc<Agent>) -> AgentAdvisor

Wrap an Agent as an advisor-driving AdvisorAgent.

pub fn with_post_prompt_hook( agent: Arc<Agent>, hook: Arc<dyn Fn(&Agent) + Send + Sync>, ) -> AgentAdvisor

Wrap an Agent with a hook fired after each successful advisor prompt. Used by the host to persist advisor turns to <session>/__advisor.jsonl for stats attribution / observability.

pub fn agent(&self) -> &Agent

Access the underlying agent (for transcript-recorder / event wiring).

pub fn into_agent(self) -> Arc<Agent>

Clone the underlying agent handle (cheap — Arc clone).

Trait Implementations

impl AdvisorAgent for AgentAdvisor

fn prompt<'life0, 'async_trait>( &'life0 self, input: String, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

where 'life0: 'async_trait, AgentAdvisor: 'async_trait,

Drive one advisor turn from the given batch text. Err marks the turn failed (triggers the retry/drop-after-3 path).

fn abort(&self, _reason: &str)

Abort any in-flight prompt (best-effort). omp abort.

fn reset(&self)

Reset the advisor’s own conversation state. omp reset.

fn rollback_to<'life0, 'async_trait>( &'life0 self, count: usize, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, AgentAdvisor: 'async_trait,

Drop messages appended past count. Called after a failed prompt so a retry doesn’t replay the failed user batch. omp rollbackTo.

fn message_count(&self) -> usize

Current advisor message count (for the rollback snapshot).