Struct AgentSession 

pub struct AgentSession { /* private fields */ }

Implementations

impl AgentSession

pub fn subscribe(&mut self, listener: SessionEventHandler) -> SessionListenerId

pub fn unsubscribe(&mut self, listener_id: SessionListenerId) -> bool

impl AgentSession

pub fn follow_up(&mut self, prompt: impl Into<String>) -> Result<(), String>

pub fn steer(&mut self, prompt: impl Into<String>) -> Result<(), String>

pub fn steering_handle(&self) -> SessionSteeringHandle

pub fn cancellation_handle(&self) -> SessionCancellationHandle

pub fn cancel(&self) -> bool

pub fn clear_queues(&mut self)

pub fn continue_run( &mut self, prompt: Option<String>, ) -> Result<AgentRun, String>

impl AgentSession

pub fn prompt(&mut self, prompt: impl Into<String>) -> Result<AgentRun, String>

pub fn prompt_with_auto_follow_up( &mut self, prompt: impl Into<String>, auto_follow_up: bool, ) -> Result<AgentRun, String>

impl AgentSession

pub fn query(&mut self, prompt: impl Into<String>) -> Result<String, String>

pub fn query_with_require_completed( &mut self, prompt: impl Into<String>, require_completed: bool, ) -> Result<String, String>

impl AgentSession

pub fn state(&self) -> AgentSessionState

impl AgentSession

pub fn new( execute_run: Arc<dyn Fn(String) -> Result<AgentRun, String> + Send + Sync>, agent_name: impl Into<String>, definition: AgentDefinition, workspace: impl Into<PathBuf>, ) -> Self

pub fn new_with_session_id( execute_run: Arc<dyn Fn(String) -> Result<AgentRun, String> + Send + Sync>, session_id: impl Into<String>, agent_name: impl Into<String>, definition: AgentDefinition, workspace: impl Into<PathBuf>, ) -> Self

pub fn new_with_context( execute_run: Arc<dyn Fn(AgentSessionRunRequest) -> Result<AgentRun, String> + Send + Sync>, agent_name: impl Into<String>, definition: AgentDefinition, workspace: impl Into<PathBuf>, ) -> Self

pub fn new_with_context_and_shared_state( execute_run: Arc<dyn Fn(AgentSessionRunRequest) -> Result<AgentRun, String> + Send + Sync>, agent_name: impl Into<String>, definition: AgentDefinition, workspace: impl Into<PathBuf>, shared_state: Metadata, ) -> Self

pub fn new_with_context_and_session_id( execute_run: Arc<dyn Fn(AgentSessionRunRequest) -> Result<AgentRun, String> + Send + Sync>, session_id: impl Into<String>, agent_name: impl Into<String>, definition: AgentDefinition, workspace: impl Into<PathBuf>, ) -> Self

pub fn new_with_context_and_session_id_and_shared_state( execute_run: Arc<dyn Fn(AgentSessionRunRequest) -> Result<AgentRun, String> + Send + Sync>, session_id: impl Into<String>, agent_name: impl Into<String>, definition: AgentDefinition, workspace: impl Into<PathBuf>, shared_state: Metadata, ) -> Self

pub fn session_id(&self) -> &str

pub fn agent_name(&self) -> &str

pub fn definition(&self) -> &AgentDefinition

pub fn workspace(&self) -> &Path

pub fn messages(&self) -> Vec<Message>

pub fn shared_state(&self) -> Metadata

pub fn latest_run(&self) -> Option<AgentRun>

pub fn running(&self) -> bool