Struct SampleQueue 

pub struct SampleQueue { /* private fields */ }

Active learning sample queue.

Implementations

impl SampleQueue

pub fn new(strategy: SelectionStrategy) -> Self

Create a new sample queue.

pub fn with_max_pending(self, max: usize) -> Self

Set maximum pending queue size.

pub fn strategy(&self) -> SelectionStrategy

Get selection strategy.

pub fn pending_count(&self) -> usize

Get pending count.

pub fn labeled_count(&self) -> usize

Get labeled count.

pub fn total_processed(&self) -> u64

Get total processed.

pub fn enqueue(&mut self, sample: UncertainSample) -> u64

Add an uncertain sample to the queue.

pub fn next_for_labeling(&mut self) -> Option<UncertainSample>

Get next sample for labeling (highest uncertainty).

pub fn peek_next(&self) -> Option<&UncertainSample>

Peek at next sample without removing.

pub fn batch_for_labeling(&mut self, n: usize) -> Vec<UncertainSample>

Get top N samples for batch labeling.

pub fn submit_labeled(&mut self, sample: UncertainSample)

Submit a labeled sample.

pub fn get_labeled_samples(&self) -> &[UncertainSample]

Get all labeled samples for training.

pub fn take_labeled_samples(&mut self) -> Vec<UncertainSample>

Take labeled samples (moves them out).

pub fn clear_pending(&mut self)

Clear all pending samples.

pub fn stats(&self) -> QueueStats

Get statistics.

Trait Implementations

impl Clone for SampleQueue

fn clone(&self) -> SampleQueue

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SampleQueue

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

Formats the value using the given formatter.

impl Default for SampleQueue

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for SampleQueue

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for SampleQueue

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.