Struct ComponentManager 

pub struct ComponentManager { /* private fields */ }

Manages shared, lazily-initialized pipeline components.

Each component is created on first access and cached for subsequent calls. When the underlying ConfigManager’s version advances (due to a setter call), cached components are lazily re-created on the next access.

Constructed from ConfigManager — typically loaded once via ConfigManager::from_env() or ConfigManager::new(settings).

Implementations

impl ComponentManager

pub fn new(config: ConfigManager) -> Self

pub fn settings(&self) -> RwLockReadGuard<'_, Settings>

Read-only snapshot of current settings.

Returns a RwLockReadGuard that auto-derefs to &Settings. Most call sites that use cm.settings().field_name work unchanged.

pub fn config(&self) -> &ConfigManager

Access the underlying ConfigManager for runtime mutation.

pub async fn transcriber( &self, ) -> Result<Option<Arc<dyn Transcriber>>, ComponentError>

Return the Transcriber for the configured LLM provider, if supported.

Returns Ok(Some(_)) for OpenAI (Whisper). Returns Ok(None) for providers that do not support audio transcription (e.g. litert), so callers can skip registering the AudioLoader rather than failing.

Trait Implementations

impl PipelineContext for ComponentManager

fn storage<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn StorageTrait>, ComponentError>> + Send + 'async_trait>>

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

fn database<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Arc<DatabaseConnection>, ComponentError>> + Send + 'async_trait>>

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

fn graph_db<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn GraphDBTrait>, ComponentError>> + Send + 'async_trait>>

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

fn vector_db<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn VectorDB>, ComponentError>> + Send + 'async_trait>>

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

fn embedding_engine<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn EmbeddingEngine>, ComponentError>> + Send + 'async_trait>>

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

fn llm<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn Llm>, ComponentError>> + Send + 'async_trait>>

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