github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2024-11-21 14:44:00 +00:00
Code Issues Projects Releases Packages Wiki Activity
VictoriaMetrics/lib/streamaggr
History
Aliaksandr Valialkin 48a425898a
lib/streamaggr: enable time alignment for aggregate flushed to multiples of interval 
For example, if `interval: 1m`, then data flush occurs at the end of every minute,
while `interval: 1h` leads to data flush at the end of every hour.

Add `no_align_flush_to_interval` option, which can be used for disabling the alignment.
2024-03-04 06:23:35 +02:00
..
avg.go lib/streamaggr: flush dedup state and aggregation state in parallel on all the available CPU cores 2024-03-04 01:22:41 +02:00
count_samples.go lib/streamaggr: flush dedup state and aggregation state in parallel on all the available CPU cores 2024-03-04 01:22:41 +02:00
count_series.go lib/streamaggr: flush dedup state and aggregation state in parallel on all the available CPU cores 2024-03-04 01:22:41 +02:00
dedup.go lib/streamaggr: flush dedup state and aggregation state in parallel on all the available CPU cores 2024-03-04 01:22:41 +02:00
dedup_test.go lib/streamaggr: flush dedup state and aggregation state in parallel on all the available CPU cores 2024-03-04 01:22:41 +02:00
dedup_timing_test.go lib/streamaggr: add a benchmark for flushing dedup state 2024-03-04 01:22:40 +02:00
histogram_bucket.go lib/streamaggr: flush dedup state and aggregation state in parallel on all the available CPU cores 2024-03-04 01:22:41 +02:00
last.go lib/streamaggr: flush dedup state and aggregation state in parallel on all the available CPU cores 2024-03-04 01:22:41 +02:00
max.go lib/streamaggr: flush dedup state and aggregation state in parallel on all the available CPU cores 2024-03-04 01:22:41 +02:00
min.go lib/streamaggr: flush dedup state and aggregation state in parallel on all the available CPU cores 2024-03-04 01:22:41 +02:00
quantiles.go lib/streamaggr: flush dedup state and aggregation state in parallel on all the available CPU cores 2024-03-04 01:22:41 +02:00
stddev.go lib/streamaggr: flush dedup state and aggregation state in parallel on all the available CPU cores 2024-03-04 01:22:41 +02:00
stdvar.go lib/streamaggr: flush dedup state and aggregation state in parallel on all the available CPU cores 2024-03-04 01:22:41 +02:00
streamaggr.go lib/streamaggr: enable time alignment for aggregate flushed to multiples of interval 2024-03-04 06:23:35 +02:00
streamaggr_test.go lib/streamaggr: enable time alignment for aggregate flushed to multiples of interval 2024-03-04 06:23:35 +02:00
streamaggr_timing_test.go lib/streamaggr: enable time alignment for aggregate flushed to multiples of interval 2024-03-04 06:23:35 +02:00
sum_samples.go lib/streamaggr: flush dedup state and aggregation state in parallel on all the available CPU cores 2024-03-04 01:22:41 +02:00
total.go lib/streamaggr: ignore the first sample in new time series during staleness_interval seconds after the stream aggregation start for total and increase outputs 2024-03-04 03:04:58 +02:00
unique_samples.go lib/streamaggr: flush dedup state and aggregation state in parallel on all the available CPU cores 2024-03-04 01:22:41 +02:00