github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2025-03-11 15:34:56 +00:00
Code Issues Projects Releases Packages Wiki Activity

lib/promscrape: code cleanup: send stale markers immediately after generating automatic metrics

Browse source 
This cleanup has been extracted from https://github.com/VictoriaMetrics/VictoriaMetrics/pull/5557/files#diff-6b205cf6637d7b65a5c45d9417d08822d4efad94227268cb196f61aa2a0fc0f7
This commit is contained in:
Aliaksandr Valialkin 2024-01-21 05:18:08 +02:00
parent e15f07d989
commit be5faef552
No known key found for this signature in database
GPG key ID: 52C003EE2BCDB9EB
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
lib/promscrape/scrapework.go
View file

@ -832,9 +832,9 @@ func (sw *scrapeWork) sendStaleSeries(lastScrape, currScrape string, timestamp i
if addAutoSeries { if addAutoSeries {
am := &autoMetrics{} am := &autoMetrics{}
sw.addAutoMetrics(am, wc, timestamp) sw.addAutoMetrics(am, wc, timestamp)
setStaleMarkersForRows(wc.writeRequest.Timeseries)
sw.pushData(sw.Config.AuthToken, &wc.writeRequest)
} }
setStaleMarkersForRows(wc.writeRequest.Timeseries)
sw.pushData(sw.Config.AuthToken, &wc.writeRequest)
} }
func setStaleMarkersForRows(series []prompbmarshal.TimeSeries) { func setStaleMarkersForRows(series []prompbmarshal.TimeSeries) {