Struct OnlineLearningModel 

pub struct OnlineLearningModel { /* private fields */ }

Online learning model

Implementations

impl OnlineLearningModel

pub fn new( model_type: ModelType, feature_dim: usize, config: OnlineLearningConfig, ) -> Self

Create a new online learning model

pub async fn partial_fit(&self, sample: Sample) -> Result<(), StreamError>

Partial fit with a single sample

pub async fn partial_fit_batch( &self, samples: Vec<Sample>, ) -> Result<(), StreamError>

Partial fit with multiple samples

pub async fn predict(&self, features: &[f64]) -> Result<Prediction, StreamError>

Make a prediction

pub async fn predict_ab( &self, features: &[f64], ) -> Result<Prediction, StreamError>

Predict with A/B testing

pub async fn detect_drift(&self) -> Result<DriftDetection, StreamError>

Detect concept drift

pub async fn checkpoint(&self) -> Result<String, StreamError>

Create a checkpoint

pub async fn restore(&self, checkpoint_id: &str) -> Result<(), StreamError>

Restore from checkpoint

pub async fn start_ab_test( &self, config: ABTestConfig, ) -> Result<(), StreamError>

Start A/B test

pub async fn stop_ab_test(&self) -> Result<Option<ABTestResult>, StreamError>

Stop A/B test and get results

pub async fn get_weights(&self) -> Vec<f64>

Get current model weights

pub async fn get_metrics(&self) -> ModelMetrics

Get current metrics

pub async fn get_stats(&self) -> OnlineLearningStats

Get statistics

pub async fn get_checkpoints(&self) -> Vec<ModelCheckpoint>

Get all checkpoints

pub async fn reset(&self)

Reset model