Struct ContinuousAggregateSpec 

pub struct ContinuousAggregateSpec {
    pub name: String,
    pub source: String,
    pub bucket_size_ns: u64,
    pub columns: Vec<ContinuousAggregateColumn>,
    pub refresh_lag_ns: u64,
    pub max_interval_per_job_ns: u64,
}

Fields

name: String

source: String

Source time-series / hypertable this aggregate reads from.

bucket_size_ns: u64

Size of the time bucket in nanoseconds.

columns: Vec<ContinuousAggregateColumn>

Aggregated columns.

refresh_lag_ns: u64

Lag (ns) between now() and the newest bucket the refresh daemon is willing to materialise. Matches Timescale’s start_offset — stops us from materialising a bucket whose source rows are still landing.

max_interval_per_job_ns: u64

Maximum span (ns) a single refresh will materialise at once. Timescale calls this max_interval_per_job.

Implementations

impl ContinuousAggregateSpec

pub fn from_durations( name: impl Into<String>, source: impl Into<String>, bucket: &str, columns: Vec<ContinuousAggregateColumn>, refresh_lag: &str, max_interval_per_job: &str, ) -> Option<ContinuousAggregateSpec>

Convenience constructor from string durations.

pub fn bucket_start(&self, ts_ns: u64) -> u64

Align timestamp to bucket floor.

pub fn bucket_end_exclusive(&self, ts_ns: u64) -> u64

Trait Implementations

impl Clone for ContinuousAggregateSpec

fn clone(&self) -> ContinuousAggregateSpec

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ContinuousAggregateSpec

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

Formats the value using the given formatter.