Struct MocoQueue 

pub struct MocoQueue {
    pub capacity: usize,
    pub dim: usize,
    pub data: Vec<f32>,
    pub head: usize,
    pub len: usize,
}

FIFO circular queue of D-dimensional embedding vectors.

Fields

capacity: usize

Capacity (max number of stored vectors).

dim: usize

Embedding dimensionality.

data: Vec<f32>

Backing storage: [capacity × dim] flat row-major buffer.

head: usize

Index where the next enqueue writes (mod capacity).

len: usize

Number of valid entries currently in the queue (<= capacity).

Implementations

impl MocoQueue

pub fn new(capacity: usize, dim: usize) -> SslResult<Self>

Create an empty queue with given capacity and embedding dim.

Errors

• SslError::QueueCapacityTooSmall if capacity == 0.
• SslError::InvalidFeatureDim if dim == 0.

pub fn enqueue(&mut self, batch: &[f32]) -> SslResult<()>

Enqueue a batch of [batch × dim] row-major key embeddings. Old entries are evicted FIFO if the queue overflows.

Errors

• SslError::DimensionMismatch when batch.len() % self.dim != 0.

pub fn len(&self) -> usize

Number of currently stored entries (≤ capacity).

pub fn is_empty(&self) -> bool

True if the queue is empty.

pub fn entries(&self) -> &[f32]

Snapshot of the currently stored entries in the order they appear in the backing buffer (i.e., not strictly chronological — both directions are negatives, so order does not matter).

Trait Implementations

impl Clone for MocoQueue

fn clone(&self) -> MocoQueue

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MocoQueue

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

Formats the value using the given formatter.