Struct EmbeddingProviderComponent 

pub struct EmbeddingProviderComponent { /* private fields */ }

A Component that wraps an existing EmbeddingProvider.

Implementations

impl EmbeddingProviderComponent

pub fn new( name: impl Into<String>, provider: Arc<dyn EmbeddingProvider>, ) -> Self

Construct a wrapper around a pre-built embedding provider.

pub fn provider(&self) -> &Arc<dyn EmbeddingProvider>

Borrow the inner provider.

Trait Implementations

impl Component for EmbeddingProviderComponent

const NAME: &'static str = "EmbeddingProviderComponent"

Stable identifier for the component kind (e.g. "provider.openai", "store.session.redis"). Used in configuration and logging.

type Config = EmptyConfig

Configuration shape. Must be deserializable from JSON/YAML/TOML and must produce a valid JSON Schema for documentation and validation.

type Error = WrapperError

Error type for lifecycle phases. Must implement std::error::Error so the registry can chain and format errors uniformly.

fn init<'life0, 'life1, 'async_trait>( _cfg: &'life0 Self::Config, _ctx: &'life1 ComponentContext, ) -> Pin<Box<dyn Future<Output = Result<Self, Self::Error>> + Send + 'async_trait>>

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

Construct a component instance from its validated configuration.

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

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

Begin serving. Default is a no-op. Override to spawn workers, open connections, or warm caches.

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

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

Stop serving. Default is a no-op. Override to drain queues, close connections, and persist state.

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

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

Non-mutating health probe. Default is HealthStatus::healthy. Override to surface upstream connectivity, queue depth, retry pressure, etc.

fn depends_on() -> &'static [&'static str]

Names of components this component depends on. Used by the registry to build a dependency graph and drive ordered initialization.

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

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

Called before this component is replaced by a new instance.

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

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

Called after this component has been replaced by a new instance.

impl Debug for EmbeddingProviderComponent

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.