Struct EmbeddingRegistry 

pub struct EmbeddingRegistry { /* private fields */ }

Generic Qdrant-backed embedding registry.

Owns a QdrantOps instance, a collection name and a UUID namespace for deterministic point IDs (uuid v5). The in-memory hashes map enables O(1) delta detection between syncs.

Implementations

impl EmbeddingRegistry

pub fn new( ops: QdrantOps, collection: impl Into<String>, namespace: Uuid, ) -> Self

Create a registry wrapping an existing QdrantOps connection.

pub async fn sync<T: Embeddable>( &mut self, items: &[T], embedding_model: &str, embed_fn: impl Fn(&str) -> EmbedFuture, ) -> Result<SyncStats, EmbeddingRegistryError>

Sync items into Qdrant, computing a content-hash delta to avoid unnecessary re-embedding. Re-creates the collection when the embedding model changes.

Errors

Returns EmbeddingRegistryError on Qdrant or embedding failures.

pub async fn search_raw( &self, query: &str, limit: usize, embed_fn: impl Fn(&str) -> EmbedFuture, ) -> Result<Vec<ScoredVectorPoint>, EmbeddingRegistryError>

Search the collection, returning raw scored Qdrant points.

Consumers map the payloads to their domain types.

Errors

Returns EmbeddingRegistryError if embedding or Qdrant search fails.

Trait Implementations

impl Debug for EmbeddingRegistry

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

Formats the value using the given formatter.