Struct ContinuousForecastEngine 

pub struct ContinuousForecastEngine { /* private fields */ }

Continuous forecast engine — re-fits models as new data arrives.

Implementations

impl ContinuousForecastEngine

pub fn new() -> Self

Create a new continuous forecast engine.

pub fn enable(&self, config: ContinuousForecastConfig) -> Result<()>

Enable continuous forecasting for a measurement.

pub fn disable(&self, measurement: &str)

Disable continuous forecasting for a measurement.

pub fn is_enabled(&self, measurement: &str) -> bool

Check if a measurement has continuous forecasting enabled.

pub fn process_point( &self, measurement: &str, tags: &BTreeMap<String, String>, fields: &BTreeMap<String, FieldValue>, timestamp: i64, ) -> Option<ForecastUpdate>

Process a new data point for a series.

Returns the update type if the model was updated.

pub fn predict( &self, measurement: &str, tags: &BTreeMap<String, String>, horizon: usize, ) -> Result<ForecastResult>

Get a forecast for a series.

pub fn config_count(&self) -> usize

Number of configured measurements.

pub fn series_count(&self) -> usize

Number of tracked series.

Trait Implementations

impl Default for ContinuousForecastEngine

fn default() -> Self

Returns the “default value” for a type.