Struct AgentRegistry 

pub struct AgentRegistry { /* private fields */ }

Agent 注册中心

提供 Agent 的注册、发现、工厂创建功能

示例

use mofa_runtime::agent::AgentRegistry;
use mofa_kernel::agent::config::AgentConfig;

let registry = AgentRegistry::new();

// 注册工厂
registry.register_factory(Arc::new(LLMAgentFactory)).await?;

// 通过工厂创建 Agent
let config = AgentConfig::new("agent-1", "My Agent", "llm");
let agent = registry.create("llm", config).await?;

// 注册 Agent
registry.register(agent).await?;

// 查找 Agent
let found = registry.get("agent-1").await;

Implementations

impl AgentRegistry

pub fn new() -> AgentRegistry

创建新的注册中心

pub async fn register( &self, agent: Arc<RwLock<dyn MoFAAgent>>, ) -> Result<(), AgentError>

注册 Agent

pub async fn get(&self, id: &str) -> Option<Arc<RwLock<dyn MoFAAgent>>>

获取 Agent

pub async fn unregister(&self, id: &str) -> Result<bool, AgentError>

移除 Agent

pub async fn get_metadata(&self, id: &str) -> Option<AgentMetadata>

获取 Agent 元数据

pub async fn list(&self) -> Vec<AgentMetadata>

列出所有 Agent

pub async fn count(&self) -> usize

获取 Agent 数量

pub async fn contains(&self, id: &str) -> bool

检查 Agent 是否存在

pub async fn find_by_capabilities( &self, requirements: &AgentRequirements, ) -> Vec<AgentMetadata>

按能力要求查找 Agent

pub async fn find_by_tag(&self, tag: &str) -> Vec<AgentMetadata>

按标签查找 Agent

pub async fn find_by_tags(&self, tags: &[String]) -> Vec<AgentMetadata>

按多个标签查找 Agent (交集)

pub async fn find_by_state(&self, state: AgentState) -> Vec<AgentMetadata>

按状态查找 Agent

pub async fn register_factory( &self, factory: Arc<dyn AgentFactory>, ) -> Result<(), AgentError>

注册 Agent 工厂

pub async fn get_factory(&self, type_id: &str) -> Option<Arc<dyn AgentFactory>>

获取 Agent 工厂

pub async fn unregister_factory( &self, type_id: &str, ) -> Result<bool, AgentError>

移除 Agent 工厂

pub async fn list_factory_types(&self) -> Vec<String>

列出所有工厂类型

pub async fn create( &self, type_id: &str, config: AgentConfig, ) -> Result<Arc<RwLock<dyn MoFAAgent>>, AgentError>

通过工厂创建 Agent

pub async fn create_and_register( &self, type_id: &str, config: AgentConfig, ) -> Result<Arc<RwLock<dyn MoFAAgent>>, AgentError>

创建并注册 Agent

pub async fn initialize_all( &self, ctx: &AgentContext, ) -> Result<Vec<String>, AgentError>

初始化所有 Agent

pub async fn shutdown_all(&self) -> Result<Vec<String>, AgentError>

关闭所有 Agent

pub async fn clear(&self) -> Result<usize, AgentError>

清空所有 Agent

impl AgentRegistry

pub async fn stats(&self) -> RegistryStats

获取统计信息

Trait Implementations

impl Default for AgentRegistry

fn default() -> AgentRegistry

Returns the “default value” for a type.