Struct AcquisitionStream 

pub struct AcquisitionStream { /* private fields */ }

An interleaved acquisition stream of timing measurements.

Measurement produces an interleaved stream indexed by acquisition time: {(c_t, y_t)} where c_t is the class label and y_t is the timing.

This structure is critical for correct dependence estimation. The underlying stochastic process operates in continuous time—drift, frequency scaling, and cache state evolution affect nearby samples regardless of class. Bootstrap resampling must preserve adjacency in acquisition order, not per-class position.

See spec Section 2.3.1 for the full rationale.

Implementations

impl AcquisitionStream

pub fn new() -> Self

Create a new empty acquisition stream.

pub fn with_capacity(capacity: usize) -> Self

Create a new acquisition stream with pre-allocated capacity.

pub fn push(&mut self, class: SampleClass, timing: f64)

Push a new sample onto the stream.

pub fn push_batch_interleaved(&mut self, fixed: &[f64], random: &[f64])

Push a batch of samples, interleaving Fixed and Random classes.

Samples are pushed in interleaved order: F, R, F, R, … Both vectors must have the same length.

pub fn len(&self) -> usize

Get the total number of samples in the stream.

pub fn is_empty(&self) -> bool

Check if the stream is empty.

pub fn n_per_class(&self) -> usize

Get the number of samples per class (assumes balanced classes).

pub fn split_by_class(&self) -> (Vec<f64>, Vec<f64>)

Split the stream into per-class vectors.

Returns (fixed_timings, random_timings).

pub fn timings(&self) -> impl Iterator<Item = f64> + '_

Get an iterator over all timings (ignoring class labels).

Used for ACF computation on the pooled stream.

pub fn as_slice(&self) -> &[(SampleClass, f64)]

Get a slice of the raw samples.

pub fn as_mut_slice(&mut self) -> &mut [(SampleClass, f64)]

Get mutable access to the raw samples.

pub fn iter(&self) -> impl Iterator<Item = &(SampleClass, f64)>

Get an iterator over (class, timing) pairs.

pub fn clear(&mut self)

Clear the stream, removing all samples but keeping capacity.

pub fn truncate(&mut self, len: usize)

Truncate the stream to the given length.

pub fn get(&self, index: usize) -> Option<&(SampleClass, f64)>

Get the sample at the given index.

pub fn from_raw_interleaved( baseline: &[u64], sample: &[u64], ns_per_tick: f64, ) -> Self

Convert raw u64 measurements to nanoseconds and store as stream.

Interleaves the measurements: baseline[0], sample[0], baseline[1], sample[1], …

pub fn to_timing_samples(&self) -> Vec<TimingSample>

Convert to Vec for bootstrap functions.

This is an adapter method that converts the acquisition stream to the TimingSample format used by the bootstrap covariance estimation functions.

Maps SampleClass::Fixed → Class::Baseline, SampleClass::Random → Class::Sample.

Trait Implementations

impl Clone for AcquisitionStream

fn clone(&self) -> AcquisitionStream

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AcquisitionStream

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

Formats the value using the given formatter.

impl Default for AcquisitionStream

fn default() -> AcquisitionStream

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for AcquisitionStream

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for AcquisitionStream

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

where __S: Serializer,

Serialize this value into the given Serde serializer.