Struct ContinuousAggregateEngine 

pub struct ContinuousAggregateEngine { /* private fields */ }

Implementations

impl ContinuousAggregateEngine

pub fn new() -> Self

pub fn register(&self, spec: ContinuousAggregateSpec)

pub fn drop_aggregate(&self, name: &str)

pub fn list(&self) -> Vec<ContinuousAggregateSpec>

pub fn state(&self, name: &str) -> Option<ContinuousAggregateState>

pub fn refresh( &self, name: &str, now_ns: u64, source: &ContinuousAggregateSource, ) -> u64

Refresh a single aggregate: consult now_ns, compute the [start, end) window that can safely land (bounded by refresh_lag_ns and max_interval_per_job_ns), call the source callback, and fold the returned points into the materialised buckets. Returns the number of points absorbed.

Trait Implementations

impl Clone for ContinuousAggregateEngine

fn clone(&self) -> ContinuousAggregateEngine

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ContinuousAggregateEngine

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

Formats the value using the given formatter.

impl Default for ContinuousAggregateEngine

fn default() -> Self

Returns the “default value” for a type.