Struct TimeMatrix 

pub struct TimeMatrix<F, P>
where
    F: SerialStatistic<P>,
    P: InterpolationKind,
{ /* private fields */ }

One or more statistical round-robin time series.

A time matrix is a round-robin multi-resolution time series that samples and interpolates timed data, computes statistical aggregations for elapsed sampling intervals, and buffers those aggregations. The sample data, statistic, and interpolation of series in a time matrix must be the same, but the sampling intervals can and should differ.

Implementations

impl<F, P> TimeMatrix<F, P>

where F: SerialStatistic<P>, P: InterpolationKind,

pub fn new( profile: impl Into<SamplingProfile>, interpolation: P::Output<F::Sample>, ) -> Self

where F: Default,

Constructs a time matrix with the given sampling profile and interpolation.

Statistics are default initialized.

pub fn with_statistic( profile: impl Into<SamplingProfile>, interpolation: P::Output<F::Sample>, statistic: F, ) -> Self

Constructs a time matrix with the given statistic.

pub fn fold_and_get_buffers( &mut self, sample: Timed<F::Sample>, ) -> Result<SerializedBuffer, FoldError>

Folds the given sample and interpolations and gets the aggregation buffers.

To fold a sample without serializing buffers, use Sampler::fold.

impl<F, R, P, A> TimeMatrix<PostAggregation<F, R>, P>

where PostAggregation<F, R>: SerialStatistic<P, Aggregation = A>, F: Default + SerialStatistic<P>, R: Clone + Fn(F::Aggregation) -> A, P: InterpolationKind, A: Clone,

pub fn with_transform( profile: impl Into<SamplingProfile>, interpolation: P::Output<<PostAggregation<F, R> as Statistic>::Sample>, transform: R, ) -> Self

where R: Clone,

Constructs a time matrix with the default statistic and given transform for post-aggregation.

Trait Implementations

impl<F, P> Clone for TimeMatrix<F, P>

where F: SerialStatistic<P> + Clone, P: InterpolationKind, F::Buffer: Clone, P::Output<F::Sample>: Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<F, P> Debug for TimeMatrix<F, P>

where F: SerialStatistic<P> + Debug, P: InterpolationKind, F::Buffer: Debug, P::Output<F::Sample>: Debug,

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

Formats the value using the given formatter.

impl<F, P> Default for TimeMatrix<F, P>

where F: Default + SerialStatistic<P>, P: InterpolationKind, P::Output<F::Sample>: Default,

fn default() -> Self

Returns the “default value” for a type.

impl<F, P> Interpolator for TimeMatrix<F, P>

where F: SerialStatistic<P>, P: InterpolationKind,

fn interpolate(&mut self, timestamp: Timestamp) -> Result<(), FoldError>

Interpolates samples to the given timestamp.

fn interpolate_and_get_buffers( &mut self, timestamp: Timestamp, ) -> Result<SerializedBuffer, FoldError>

Interpolates samples to the given timestamp and gets the serialized aggregation buffers.

impl<F, P> MatrixSampler<<F as Statistic>::Sample> for TimeMatrix<F, P>

where F: SerialStatistic<P>, P: InterpolationKind,

fn fold(&mut self, sample: Timed<F::Sample>) -> Result<(), FoldError>