Struct EmbeddingPipeline 

pub struct EmbeddingPipeline<'a> { /* private fields */ }

Manages embedding computation and semantic index storage.

Implementations

impl<'a> EmbeddingPipeline<'a>

pub fn new(model: &'a SemanticModel, db: &'a Connection) -> Result<Self>

Construct a pipeline and ensure semantic tables exist.

Errors

Returns an error if the database schema creation fails.

pub fn embed_item(&self, item: &WorkItemFields) -> Result<bool>

Embed a single item and upsert its vector if content changed.

Errors

Returns an error if inference or the database upsert fails.

pub fn embed_all(&self, items: &[WorkItemFields]) -> Result<usize>

Batch-embed multiple items.

Errors

Returns an error if batch inference or any database upsert fails.