Struct EmbeddingService 

pub struct EmbeddingService<S, E>
where
    S: DatasetStore,
    E: EmbeddingProvider,
{ /* private fields */ }

Standalone service for generating embeddings for datasets already in the database.

Queries datasets with embedding IS NULL, generates embeddings in batches through a circuit breaker, and upserts them back to the database.

Implementations

impl<S, E> EmbeddingService<S, E>

where S: DatasetStore, E: EmbeddingProvider,

pub fn new(store: S, embedding: E) -> Self

Creates a new embedding service with default configuration.

pub fn with_config( store: S, embedding: E, config: EmbeddingServiceConfig, ) -> Self

Creates a new embedding service with custom configuration.

pub fn embedding_provider(&self) -> &E

Returns a reference to the underlying embedding provider.

pub async fn embed_pending( &self, portal_filter: Option<&str>, reporter: &impl ProgressReporter, cancel_token: CancellationToken, ) -> Result<EmbeddingStats, AppError>

Embeds all datasets with embedding IS NULL.

Fetches pending datasets from the database, generates embeddings in batches through the circuit breaker, and upserts them back.

Arguments

• portal_filter - Optional portal URL to scope the embedding pass
• reporter - Progress reporter for UI/logging
• cancel_token - Token for graceful cancellation

Trait Implementations

impl<S, E> Clone for EmbeddingService<S, E>

where S: DatasetStore + Clone, E: EmbeddingProvider + Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.