Method list_aggregates

nodedb/src/engine/timeseries/continuous_agg/manager.rs:240–261

List all registered aggregates with status.

(&self)

    /// List all registered aggregates with status.
    pub fn list_aggregates(&self) -> Vec<AggregateInfo> {
        self.definitions
            .values()
            .map(|def| {
                let wm = self.watermarks.get(&def.name);
                let bucket_count = self
                    .materialized
                    .get(&def.name)
                    .map_or(0, |m| m.len() as u64);
                AggregateInfo {
                    name: def.name.clone(),
                    source: def.source.clone(),
                    bucket_interval: def.bucket_interval.clone(),
                    refresh_policy: def.refresh_policy.clone(),
                    watermark_ts: wm.map_or(i64::MIN, |w| w.watermark_ts),
                    rows_aggregated: wm.map_or(0, |w| w.rows_aggregated),
                    materialized_buckets: bucket_count,
                    stale: def.stale,
                }
            })
            .collect()
    }
}

impl Default for ContinuousAggregateManager {