Struct SessionAgent 

pub struct SessionAgent<M, C, T, R>
where
    M: Clone + Serialize + DeserializeOwned + Into<InputItem> + Send + Sync + 'static,
    C: TypedTool + Clone + Serialize + DeserializeOwned + Send + Sync + 'static,
    T: Clone + Serialize + DeserializeOwned + Send + Sync + 'static,
    R: Clone + Serialize + DeserializeOwned + JsonSchema + Send + Sync + 'static,
{ /* private fields */ }

Default model-backed implementation of super::Agent.

SessionAgent owns the runner, context manager, execution profile, optional typed tool execution, and the mutable turn/session state required to drive a conversation.

Implementations

impl<M, C, T, R> SessionAgent<M, C, T, R>

where M: Clone + Serialize + DeserializeOwned + Into<InputItem> + Send + Sync + 'static, C: TypedTool + Clone + Serialize + DeserializeOwned + Send + Sync + 'static, T: Clone + Serialize + DeserializeOwned + Send + Sync + 'static, R: Clone + Serialize + DeserializeOwned + JsonSchema + Send + Sync + 'static,

pub async fn send(&mut self, input: AgentInput<M>) -> AgentResult<()>

pub async fn send_with_profile( &mut self, input: AgentInput<M>, profile: ExecutionProfile, ) -> AgentResult<()>

pub async fn next(&mut self) -> AgentResult<Option<AgentEvent<C, T, R>>>

pub async fn spawn( self, ) -> AgentResult<(AgentRunInput<M>, AgentRunOutput<C, T, R>)>

pub async fn transcript(&self) -> AgentResult<Vec<InputItem>>

pub fn active_turn(&self) -> Option<u64>

pub fn queued_turn_count(&self) -> usize

impl SessionAgent<String, (), (), String>

pub fn builder() -> AgentBuilder<String, (), (), String>

impl SessionAgent<InputItem, (), (), String>

pub fn raw_builder() -> AgentBuilder<InputItem, (), (), String>

Trait Implementations

impl<M, C, T, R> Agent for SessionAgent<M, C, T, R>

where M: Clone + Serialize + DeserializeOwned + Into<InputItem> + Send + Sync + 'static, C: TypedTool + Clone + Serialize + DeserializeOwned + Send + Sync + 'static, T: Clone + Serialize + DeserializeOwned + Send + Sync + 'static, R: Clone + Serialize + DeserializeOwned + JsonSchema + Send + Sync + 'static,

type Input = M

Input message type accepted by the agent.

type ToolCall = C

Tool call type emitted by the agent.

type ToolResult = T

Tool result type returned into the agent after execution.

type Output = R

Final structured reply type produced by the agent.

async fn send(&mut self, input: AgentInput<Self::Input>) -> AgentResult<()>

Sends an input into the session.

async fn next( &mut self, ) -> AgentResult<Option<AgentEvent<Self::ToolCall, Self::ToolResult, Self::Output>>>

Advances the session and yields the next event, if any.

async fn spawn( self, ) -> AgentResult<(AgentRunInput<Self::Input>, AgentRunOutput<Self::ToolCall, Self::ToolResult, Self::Output>)>

Spawns the agent as a background task and exposes channel-based I/O.

async fn cast(&mut self, input: Self::Input) -> AgentResult<()>

Sends a normal user message without waiting for completion.

async fn call(&mut self, input: Self::Input) -> AgentResult<Self::Output>

Sends a normal user message and waits for the terminal reply.

async fn steer(&mut self, input: Self::Input) -> AgentResult<Self::Output>

Sends steering input and waits for the resulting terminal reply.

async fn cancel(&mut self) -> AgentResult<()>

Requests cancellation and waits until the session observes it.