Struct SemanticEmbeddingPool 

pub struct SemanticEmbeddingPool {
    pub buffers: Vec<EmbeddingBuffer>,
    pub config: PoolConfig,
    pub stats: PoolStats,
    /* private fields */
}

Managed pool of pre-allocated, fixed-dimension embedding buffers.

Callers acquire a buffer id, write data into it, read from it, and release it back to the pool. Releasing zeroes the buffer data and increments the buffer’s generation counter so stale ids are detectable.

Fields

buffers: Vec<EmbeddingBuffer>

All buffers managed by this pool (both in-use and free).

config: PoolConfig

Pool configuration.

stats: PoolStats

Accumulated runtime statistics.

Implementations

impl SemanticEmbeddingPool

pub fn new(config: PoolConfig) -> Self

Create a new pool, pre-allocating config.initial_capacity zeroed buffers.

pub fn acquire(&mut self) -> Option<u64>

Acquire a free buffer, allocating a new one if necessary.

Returns Some(buffer_id) on success, or None when the pool is at max_capacity and every buffer is already in use.

pub fn write(&mut self, buffer_id: u64, data: &[f32]) -> bool

Write data into the buffer identified by buffer_id.

Returns false when:

• No buffer with buffer_id exists.
• The buffer is not currently in use.
• data.len() does not match the pool’s embedding dimension.

pub fn read(&self, buffer_id: u64) -> Option<&[f32]>

Read the data slice from an in-use buffer.

Returns None when the buffer is not found or is not currently in use.

pub fn release(&mut self, buffer_id: u64) -> bool

Release a buffer back to the pool.

Zeroes the buffer data and increments its generation counter. Returns false if no buffer with buffer_id is found.

pub fn clear_all(&mut self)

Release every buffer in the pool back to the free state.

pub fn stats(&self) -> PoolStats

Return a snapshot of the current pool statistics.