Struct TimeSeries 

pub struct TimeSeries<T> { /* private fields */ }

Implementations

impl<T: Default> TimeSeries<T>

pub fn new( create_aggregation_fn: impl Fn() -> Box<dyn Fn(&T, &T) -> T + Send>, ) -> Self

pub fn with_n_windows( minutely_windows: MinutelyWindows, fifteen_minutely_windows: FifteenMinutelyWindows, hourly_windows: HourlyWindows, create_aggregation_fn: impl Fn() -> Box<dyn Fn(&T, &T) -> T + Send>, ) -> Self

pub fn update_windows(&mut self)

Check whether the current time has exceeded the bound of the existing windows. If yes then slide windows as many times as required until the window encompasses the current time.

pub fn log_value(&mut self, item: &T)

Log the value into TimeSeries. This operation automatically updates the windows.

pub fn minutely_iter<'a>(&'a self) -> impl ExactSizeIterator<Item = &'a T>

Get Iterator to traverse the minutely windows

pub fn get_aggregated_value(&mut self) -> T

Get the aggregated value of the data that are still kept

pub fn record_schema(&mut self, node: &InspectNode)

impl<T: Into<u64> + Clone + Default> TimeSeries<T>

pub fn log_inspect_uint_array( &mut self, node: &InspectNode, child_name: &'static str, )

impl<T: Into<i64> + Clone + Default> TimeSeries<T>

pub fn log_inspect_int_array( &mut self, node: &InspectNode, child_name: &'static str, )

impl TimeSeries<SumAndCount>

pub fn log_avg_inspect_double_array( &mut self, node: &InspectNode, child_name: &'static str, )

Trait Implementations

impl<T: Debug> Debug for TimeSeries<T>

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

Formats the value using the given formatter.