Struct AgentTools 

pub struct AgentTools { /* private fields */ }

AgentTools provides coordination tools for multi-agent collaboration.

Implementations

impl AgentTools

pub fn new( agent_store: AgentStore, conversation_store: ConversationStore, task_store: TaskStore, event_bus: EventBus, ) -> AgentTools

pub async fn list_agents( &self, workspace_id: &str, ) -> Result<ToolResult, ServerError>

pub async fn read_agent_conversation( &self, agent_id: &str, last_n: Option<usize>, start_turn: Option<i32>, end_turn: Option<i32>, include_tool_calls: bool, ) -> Result<ToolResult, ServerError>

pub async fn create_agent( &self, name: &str, role: &str, workspace_id: &str, parent_id: Option<&str>, model_tier: Option<&str>, ) -> Result<ToolResult, ServerError>

pub async fn delegate( &self, agent_id: &str, task_id: &str, caller_agent_id: &str, ) -> Result<ToolResult, ServerError>

pub async fn message_agent( &self, from_agent_id: &str, to_agent_id: &str, message: &str, ) -> Result<ToolResult, ServerError>

pub async fn report_to_parent( &self, agent_id: &str, report: CompletionReport, ) -> Result<ToolResult, ServerError>

pub async fn create_task( &self, title: &str, objective: &str, workspace_id: &str, session_id: Option<&str>, scope: Option<&str>, acceptance_criteria: Option<Vec<String>>, verification_commands: Option<Vec<String>>, test_cases: Option<Vec<String>>, dependencies: Option<Vec<String>>, parallel_group: Option<&str>, ) -> Result<ToolResult, ServerError>

pub async fn get_task(&self, task_id: &str) -> Result<ToolResult, ServerError>

pub async fn list_tasks( &self, workspace_id: &str, ) -> Result<ToolResult, ServerError>

pub async fn update_task_status( &self, task_id: &str, status: &str, agent_id: &str, summary: Option<&str>, ) -> Result<ToolResult, ServerError>

pub async fn subscribe_to_events( &self, agent_id: &str, agent_name: &str, event_types: Vec<String>, exclude_self: bool, one_shot: bool, wait_group_id: Option<String>, priority: i32, ) -> Result<ToolResult, ServerError>

pub async fn unsubscribe_from_events( &self, subscription_id: &str, ) -> Result<ToolResult, ServerError>

pub async fn drain_pending_events( &self, agent_id: &str, ) -> Result<ToolResult, ServerError>

pub async fn get_agent_status( &self, agent_id: &str, ) -> Result<ToolResult, ServerError>

pub async fn get_agent_summary( &self, agent_id: &str, ) -> Result<ToolResult, ServerError>