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 86c7afd126
lib/streamaggr: consistently use the same timestamp across all the output aggregated samples in a single aggregation interval 
Prevsiously every aggregation output was using its own timestamp for the output aggregated samples
in a single aggregation interval. This could result in unexpected inconsitent timesetamps for the output
aggregated samples.

This commit consistently uses the same timestamp across all the output aggregated samples.
This commit makes sure that the duration between subsequent timestamps strictly equals
the configured aggregation interval.

Thanks to @AndrewChubatiuk for the original idea at https://github.com/VictoriaMetrics/VictoriaMetrics/pull/6314
This commit should help https://github.com/VictoriaMetrics/VictoriaMetrics/issues/4580
2024-08-07 11:39:13 +02:00
..
avg.go lib/streamaggr: consistently use the same timestamp across all the output aggregated samples in a single aggregation interval 2024-08-07 11:39:13 +02:00
count_samples.go lib/streamaggr: consistently use the same timestamp across all the output aggregated samples in a single aggregation interval 2024-08-07 11:39:13 +02:00
count_series.go lib/streamaggr: consistently use the same timestamp across all the output aggregated samples in a single aggregation interval 2024-08-07 11:39:13 +02:00
dedup.go lib/streamaggr: prevent from data race inside dedupAggrShard when samplesBuf can be updated in pushSamples() while their values are read in the flush() loop without das.mu lock 2024-06-11 17:31:16 +02:00
dedup_test.go lib/streamaggr: reduce memory allocations by using dedupAggrSample buffer per each dedupAggrShard 2024-06-10 16:38:42 +02:00
dedup_timing_test.go lib/streamaggr: reduce the number of duplicates per each sample in BenchmarkDedupAggr from 100 to 2 2024-06-10 16:38:41 +02:00
deduplicator.go app/vmagent/remotewrite: follow-up for f153f54d11 2024-07-15 20:24:01 +02:00
deduplicator_test.go app/vmagent/remotewrite,lib/streamaggr: re-use common code in tests after 879771808b 2024-07-03 15:21:36 +02:00
deduplicator_timing_test.go lib/streamaggr: added stale samples metric, added metrics labels (#6462) 2024-07-01 14:56:17 +02:00
histogram_bucket.go lib/streamaggr: consistently use the same timestamp across all the output aggregated samples in a single aggregation interval 2024-08-07 11:39:13 +02:00
last.go lib/streamaggr: consistently use the same timestamp across all the output aggregated samples in a single aggregation interval 2024-08-07 11:39:13 +02:00
max.go lib/streamaggr: consistently use the same timestamp across all the output aggregated samples in a single aggregation interval 2024-08-07 11:39:13 +02:00
min.go lib/streamaggr: consistently use the same timestamp across all the output aggregated samples in a single aggregation interval 2024-08-07 11:39:13 +02:00
quantiles.go lib/streamaggr: consistently use the same timestamp across all the output aggregated samples in a single aggregation interval 2024-08-07 11:39:13 +02:00
rate.go lib/streamaggr: consistently use the same timestamp across all the output aggregated samples in a single aggregation interval 2024-08-07 11:39:13 +02:00
stddev.go lib/streamaggr: consistently use the same timestamp across all the output aggregated samples in a single aggregation interval 2024-08-07 11:39:13 +02:00
stdvar.go lib/streamaggr: consistently use the same timestamp across all the output aggregated samples in a single aggregation interval 2024-08-07 11:39:13 +02:00
streamaggr.go lib/streamaggr: consistently use the same timestamp across all the output aggregated samples in a single aggregation interval 2024-08-07 11:39:13 +02:00
streamaggr_test.go app/vmagent/remotewrite: follow-up for f153f54d11 2024-07-15 20:24:01 +02:00
streamaggr_timing_test.go lib/streamaggr: consistently use the same timestamp across all the output aggregated samples in a single aggregation interval 2024-08-07 11:39:13 +02:00
sum_samples.go lib/streamaggr: consistently use the same timestamp across all the output aggregated samples in a single aggregation interval 2024-08-07 11:39:13 +02:00
total.go lib/streamaggr: consistently use the same timestamp across all the output aggregated samples in a single aggregation interval 2024-08-07 11:39:13 +02:00
unique_samples.go lib/streamaggr: consistently use the same timestamp across all the output aggregated samples in a single aggregation interval 2024-08-07 11:39:13 +02:00