Hui Wang 1c774564a2 stream aggregation: improve rate_xx results with out of order samples (#11140) ...

Previously, there could be an unexpected increase in `rate` if an
out-of-order sample was ingested after the previous flush.
Before:
<img width="1503" height="835" alt="image"
src="https://github.com/user-attachments/assets/3fb05f3e-51af-4c5c-989a-ec3da089fc23"
/>
After:
<img width="2546" height="924" alt="image"
src="https://github.com/user-attachments/assets/db8d8b0e-bbc0-4927-947a-713fc1fb4c5f"
/>

---------

Signed-off-by: hagen1778 <roman@victoriametrics.com>
Co-authored-by: hagen1778 <roman@victoriametrics.com>

2026-06-23 12:46:50 +02:00

..

avg.go

lib/streamaggr: fixed streamaggr panic (#8471)

2025-03-10 13:50:55 +01:00

count_samples.go

lib/streamaggr: fixed streamaggr panic (#8471)

2025-03-10 13:50:55 +01:00

count_series.go

lib/streamaggr: fixed streamaggr panic (#8471)

2025-03-10 13:50:55 +01:00

dedup_test.go

lib/streamaggr: expose vm_streamaggr_dedup_dropped_samples_total to track deduplicated samples

2026-06-19 09:49:09 +02:00

dedup_timing_test.go

lib/streamaggr: expose vm_streamaggr_dedup_dropped_samples_total to track deduplicated samples

2026-06-19 09:49:09 +02:00

dedup.go

lib/streamaggr: expose vm_streamaggr_dedup_dropped_samples_total to track deduplicated samples

2026-06-19 09:49:09 +02:00

deduplicator_test.go

lib/streamaggr: run go fix -rangeint

2026-02-18 14:28:30 +01:00

deduplicator_timing_test.go

lib/prompb: Merge prompbmarshal logic into prompb

2025-07-31 01:04:11 +03:00

deduplicator.go

lib/streamaggr: expose vm_streamaggr_dedup_dropped_samples_total to track deduplicated samples

2026-06-19 09:49:09 +02:00

histogram_bucket.go

chore(lib/streamaggr): move increase and increase_prometheus outputs to a separate struct (#11093)

2026-06-12 11:47:55 +02:00

increase.go

lib/streamaggr: reduce the default staleness interval

2026-06-19 09:35:22 +02:00

last.go

lib/streamaggr: fixed streamaggr panic (#8471)

2025-03-10 13:50:55 +01:00

max.go

lib/streamaggr: fixed streamaggr panic (#8471)

2025-03-10 13:50:55 +01:00

min.go

lib/streamaggr: fixed streamaggr panic (#8471)

2025-03-10 13:50:55 +01:00

output.go

chore(lib/streamaggr): move increase and increase_prometheus outputs to a separate struct (#11093)

2026-06-12 11:47:55 +02:00

quantiles.go

lib/streamaggr: fix stale quantiles output (#10918)

2026-05-11 13:12:23 +02:00

rate.go

stream aggregation: improve rate_xx results with out of order samples (#11140)

2026-06-23 12:46:50 +02:00

std.go

lib/streamaggr: fixed streamaggr panic (#8471)

2025-03-10 13:50:55 +01:00

streamaggr_synctest_test.go

stream aggregation: improve rate_xx results with out of order samples (#11140)

2026-06-23 12:46:50 +02:00

streamaggr_test.go

lib/streamaggr: reduce the default staleness interval

2026-06-19 09:35:22 +02:00

streamaggr_timing_test.go

lib/streamagrr: add sum_sample_total output function

2026-06-19 13:11:36 +02:00

streamaggr.go

lib/streamagrr: add sum_sample_total output function

2026-06-19 13:11:36 +02:00

sum_samples.go

lib/streamagrr: add sum_sample_total output function

2026-06-19 13:11:36 +02:00

total.go

lib/streamaggr: reduce the default staleness interval

2026-06-19 09:35:22 +02:00

unique_samples.go

lib/streamaggr: fixed streamaggr panic (#8471)

2025-03-10 13:50:55 +01:00