Struct EmbeddingQueue 

pub struct EmbeddingQueue { /* private fields */ }

Embedding queue for async processing

Implementations

impl EmbeddingQueue

pub fn new(batch_size: usize) -> Self

Create a new embedding queue

pub async fn queue(&self, memory_id: MemoryId, content: String) -> Result<()>

Queue a memory for embedding

pub fn queue_blocking(&self, memory_id: MemoryId, content: String) -> Result<()>

Queue a memory (blocking version for sync contexts)

pub fn len(&self) -> usize

Get queue length

pub fn is_empty(&self) -> bool

Check if queue is empty

pub fn receiver(&self) -> Receiver<EmbeddingRequest>

Get receiver for worker

Trait Implementations

impl Clone for EmbeddingQueue

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.