Struct ContinuousAggregateState 

pub struct ContinuousAggregateState { /* private fields */ }

Materialised bucket keyed by bucket-start timestamp.

Implementations

impl ContinuousAggregateState

pub fn new() -> ContinuousAggregateState

pub fn last_refreshed_bucket_ns(&self) -> u64

pub fn bucket_count(&self) -> usize

pub fn query( &self, bucket_start_ns: u64, alias: &str, agg: AggregationType, ) -> Option<f64>

Lookup a single bucket’s value for the given alias. Returns None when the bucket has not been materialised yet or the alias is unknown.

pub fn buckets(&self) -> Vec<u64>

List every materialised bucket in ascending order.

Trait Implementations

impl Clone for ContinuousAggregateState

fn clone(&self) -> ContinuousAggregateState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ContinuousAggregateState

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

Formats the value using the given formatter.

impl Default for ContinuousAggregateState

fn default() -> ContinuousAggregateState

Returns the “default value” for a type.