Struct CapabilityRegistry 

pub struct CapabilityRegistry { /* private fields */ }

Holds all runtime capabilities keyed by tool name.

Implementations

impl CapabilityRegistry

pub fn new() -> Self

pub async fn is_empty(&self) -> bool

pub async fn register( &self, cap: Arc<dyn Capability>, ) -> Result<(), RegistrationError>

pub async fn register_all( &self, capabilities: Vec<Arc<dyn Capability>>, ) -> Vec<(String, RegistrationError)>

pub async fn get(&self, name: &str) -> Option<Arc<dyn Capability>>

pub async fn catalog(&self) -> Vec<CapabilitySummary>

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

pub async fn reload_plugin( &self, plugin_name: &str, new_capabilities: Vec<Arc<dyn Capability>>, ) -> Vec<(String, RegistrationError)>

Remove all capabilities previously attributed to plugin_name, then register new_capabilities.

Holds the write lock for the entire operation so the pipeline never sees a partial tool set during hot-reload.

pub async fn reload_mcp_server( &self, server_name: &str, new_capabilities: Vec<Arc<dyn Capability>>, ) -> Result<(), RegistrationError>

Atomically replace all capabilities from a specific MCP server.

Holds the write lock for the entire operation so the pipeline never sees a partial tool set during hot-reload.

pub async fn sync_from_tool_registry( &self, registry: Arc<ToolRegistry>, ) -> Result<(), String>

Replace the catalog with one entry per tool in registry (stable name order).

pub async fn resync_tools( &self, registry: Arc<ToolRegistry>, ) -> Result<(), String>

Rebuild capabilities from tools (e.g. after hot-loading plugins into ToolRegistry).

Trait Implementations

impl Default for CapabilityRegistry

fn default() -> Self

Returns the “default value” for a type.