Struct InMemoryAgentProvider 

pub struct InMemoryAgentProvider { /* private fields */ }

内存中的Agent提供者

简单的基于内存的AgentProvider实现

Implementations

impl InMemoryAgentProvider

pub fn new() -> InMemoryAgentProvider

pub async fn add_agent(&self, agent: AgentInfo)

添加Agent

pub async fn remove_agent(&self, agent_id: &str)

移除Agent

Trait Implementations

impl AgentProvider for InMemoryAgentProvider

fn list_agents<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Vec<AgentInfo>> + Send + 'async_trait>>

where 'life0: 'async_trait, InMemoryAgentProvider: 'async_trait,

获取所有可用的Agent列表

fn get_agent<'life0, 'life1, 'async_trait>( &'life0 self, agent_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Option<AgentInfo>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryAgentProvider: 'async_trait,

根据ID获取特定Agent

fn update_agent_status<'life0, 'life1, 'async_trait>( &'life0 self, agent_id: &'life1 str, load: u32, available: bool, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryAgentProvider: 'async_trait,

更新Agent状态

fn register_agent<'life0, 'async_trait>( &'life0 self, agent: AgentInfo, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, InMemoryAgentProvider: 'async_trait,

注册新Agent（可选实现）

fn unregister_agent<'life0, 'life1, 'async_trait>( &'life0 self, agent_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryAgentProvider: 'async_trait,

注销Agent（可选实现）

fn filter_by_capabilities<'life0, 'life1, 'async_trait>( &'life0 self, capabilities: &'life1 [String], ) -> Pin<Box<dyn Future<Output = Vec<AgentInfo>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

根据能力标签筛选Agent

fn filter_by_task_type<'life0, 'life1, 'async_trait>( &'life0 self, task_type: &'life1 str, ) -> Pin<Box<dyn Future<Output = Vec<AgentInfo>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

根据任务类型筛选Agent

impl Clone for InMemoryAgentProvider

fn clone(&self) -> InMemoryAgentProvider

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for InMemoryAgentProvider

fn default() -> InMemoryAgentProvider

Returns the “default value” for a type.