Struct EmbeddingProviderRegistry 

pub struct EmbeddingProviderRegistry { /* private fields */ }

Implementations

impl EmbeddingProviderRegistry

pub fn new() -> EmbeddingProviderRegistry

pub fn with_max_blocking_concurrency( max_concurrency: usize, ) -> EmbeddingProviderRegistry

Registry with an explicit blocking-provider concurrency ceiling.

pub fn register_new( &self, provider: Arc<dyn EmbeddingProvider>, ) -> Result<u64, EmbeddingError>

pub fn register(&self, provider: Arc<dyn EmbeddingProvider>)

👎Deprecated:

use register_new and handle duplicate provider IDs

Compatibility entry point for 0.60.3 Kit clients. Duplicate IDs keep the existing provider instead of silently replacing it.

pub fn replace( &self, expected_generation: u64, provider: Arc<dyn EmbeddingProvider>, ) -> Result<u64, EmbeddingError>

pub fn get(&self, provider_id: &str) -> Option<Arc<dyn EmbeddingProvider>>

pub fn list_ids(&self) -> Vec<String>

pub fn status(&self, provider_id: &str) -> Option<ProviderStatus>

pub fn resolve( &self, source: &EmbeddingSource, ) -> Result<Arc<dyn EmbeddingProvider>, EmbeddingError>

pub fn embed( &self, source: &EmbeddingSource, texts: &[&str], expected_dim: u32, ) -> Result<Vec<Vec<f32>>, EmbeddingError>

pub fn embed_controlled( &self, source: &EmbeddingSource, texts: &[&str], expected_dim: u32, control: &ExecutionControl, trace_id: &str, limits: EmbeddingLimits, ) -> Result<Vec<Vec<f32>>, EmbeddingError>

pub async fn embed_async_controlled( &self, source: &EmbeddingSource, texts: &[&str], expected_dim: u32, control: &ExecutionControl, trace_id: &str, limits: EmbeddingLimits, ) -> Result<Vec<Vec<f32>>, EmbeddingError>

Async provider execution for server/runtime callers.

Blocking local providers run under a bounded semaphore on Tokio’s blocking pool. Remote providers must implement embed_async; both paths stop waiting when the execution control is cancelled or expires.

Trait Implementations

impl Clone for EmbeddingProviderRegistry

fn clone(&self) -> EmbeddingProviderRegistry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for EmbeddingProviderRegistry

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

Formats the value using the given formatter.

impl Default for EmbeddingProviderRegistry

fn default() -> EmbeddingProviderRegistry

Returns the “default value” for a type.