Struct ParticleRuntime 

pub struct ParticleRuntime { /* private fields */ }

Runtime for the particle-latent filter ensemble.

Implements crate::mixture::OnlineBytePredictor and provides pdf_next() for compression compatibility.

Implementations

impl ParticleRuntime

pub fn new(spec: &ParticleSpec) -> Self

Create a new particle runtime from a spec.

pub fn peek_log_prob(&mut self, symbol: u8) -> f64

Non-mutating log-probability query for a single symbol.

pub fn fill_log_probs_cached(&mut self, out: &mut [f64; 256])

Fill 256-way log-probabilities (non-mutating).

pub fn pdf_next(&mut self) -> &[f64]

Return 256-element PDF slice for compression.

pub fn step(&mut self, symbol: u8) -> f64

Observe byte y: return ln(p(y)) then update ensemble state.

pub fn reset_frozen_state(&mut self)

Reset dynamic inference state while preserving learned model parameters and particle weights.

Frozen/plugin scoring for particles intentionally keeps the learned ensemble and posterior weights from the fit pass. Only stream-local recurrent/context state is reset before the score pass begins.

pub fn update_frozen(&mut self, symbol: u8)

Advance the ensemble without SGD/model adaptation using the current observation.

This still performs the Bayesian posterior-weight update over particles, because that latent filtering step is part of the fixed model’s inference dynamics rather than a new fit/update of model parameters.

Trait Implementations

impl Clone for ParticleRuntime

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl OnlineBytePredictor for ParticleRuntime

fn log_prob(&mut self, symbol: u8) -> f64

Log-probability (natural log) of symbol given the current history.

fn fill_log_probs(&mut self, out: &mut [f64; 256])

Bulk 256-way log-probabilities for the next byte.

fn update(&mut self, symbol: u8)

Update the predictor with the observed symbol.

fn begin_stream(&mut self, _total_symbols: Option<u64>) -> Result<(), String>

Optional stream-start hook.

fn finish_stream(&mut self) -> Result<(), String>

Optional stream-finalization hook.

fn log_prob_update(&mut self, symbol: u8) -> f64

Log-probability (natural log) of symbol, then update the predictor.

fn reset_frozen(&mut self, total_symbols: Option<u64>) -> Result<(), String>

Reset only dynamic conditioning state while preserving fitted parameters/statistics.

fn update_frozen(&mut self, symbol: u8)

Advance conditioning state without fitting or adapting parameters.