Struct SystemIndexManager 

pub struct SystemIndexManager { /* private fields */ }

Manager for the system index

Implementations

impl SystemIndexManager

pub fn new() -> Self

Create a new system index manager

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

Get the current index (returns a reference to avoid cloning atomic types)

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

Get agent IDs from the index

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

Update the index version

pub async fn register_agent(&self, agent_id: String) -> Result<(), AgentError>

Register an agent in the index

pub async fn register_component( &self, component_id: String, path: String, ) -> Result<(), AgentError>

Register a component in the index

pub async fn register_model( &self, model_id: String, path: String, ) -> Result<(), AgentError>

Register a model in the index

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

Parallel directory crawler using rayon

pub fn enhanced_crawl(&self) -> Result<(), AgentError>

pub async fn bitcoin_health_check(&self) -> Result<f32, AgentError>

pub fn is_bitcoin_related(path: &Path) -> bool

Check if a path is related to Bitcoin functionality

Trait Implementations

impl Default for SystemIndexManager

fn default() -> Self

Returns the “default value” for a type.

impl IndexProvider for SystemIndexManager

fn global() -> Arc<SystemIndexManager>

Get the global system index

fn read_index<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), AgentError>> + Send + 'async_trait>>

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

Read the current index

fn increment_version<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), AgentError>> + Send + 'async_trait>>

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

Update the index