Struct MockEmbeddingEngine 

pub struct MockEmbeddingEngine { /* private fields */ }

A mock embedding engine.

Useful for testing pipeline stages that depend on an EmbeddingEngine without requiring a real model or network connection. By default it returns zero vectors (MockVectorMode::Zero); in MockVectorMode::Deterministic it derives content-stable vectors from sha256(text).

Implementations

impl MockEmbeddingEngine

pub fn new(dimensions: usize) -> Self

Create a mock engine with the given output dimensionality and a default batch size of 100.

Defaults to MockVectorMode::Zero.

pub fn with_batch_size(dimensions: usize, batch_size: usize) -> Self

Create a mock engine with explicit dimensionality and batch size.

Defaults to MockVectorMode::Zero.

pub fn deterministic(dimensions: usize) -> Self

Create a mock engine that produces deterministic, content-stable vectors derived from sha256(text) (see MockVectorMode::Deterministic).

pub fn with_mode(self, mode: MockVectorMode) -> Self

Override the vector-generation mode, consuming and returning self.

pub fn set_failure_after(&self, n: usize)

Configure the engine to fail after n successful embed calls.

With n = 0, the very first call fails. With n = 3, the first three calls succeed and the fourth and beyond fail.

pub fn call_count(&self) -> usize

Number of embed invocations observed so far (one per batched call).

pub fn embedded_text_count(&self) -> usize

Total number of texts embedded across all embed invocations.

Trait Implementations

impl EmbeddingEngine for MockEmbeddingEngine

fn embed<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, texts: &'life1 [&'life2 str], ) -> Pin<Box<dyn Future<Output = EmbeddingResult<Vec<Vec<f32>>>> + Send + 'async_trait>>

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

Embed a batch of text strings into normalized vectors

fn dimension(&self) -> usize

Get the dimensionality of embeddings produced by this engine

fn batch_size(&self) -> usize

Get the optimal batch size for this engine

fn max_sequence_length(&self) -> usize

Get the maximum sequence length (in tokens) supported