mudhorn/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus.git synced 2025-03-05 20:59:13 -08:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

clean up

Browse source 
Signed-off-by: Callum Styan <callumstyan@gmail.com>
This commit is contained in:
Callum Styan 2024-06-19 16:05:30 -07:00
parent 6c731e3603
commit 39fb4ac4f5
1 changed files with 0 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
storage/remote/queue_manager.go
View file

@ -1742,12 +1742,9 @@ func buildTimeSeries(timeSeries []prompb.TimeSeries, filter func(prompb.TimeSeri
var lowest int64 var lowest int64
var droppedSamples, droppedExemplars, droppedHistograms int var droppedSamples, droppedExemplars, droppedHistograms int
//keepIdx := 0
lowest = math.MaxInt64 lowest = math.MaxInt64
//for i, ts := range timeSeries {
timeSeries = slices.DeleteFunc(timeSeries, func(ts prompb.TimeSeries) bool { timeSeries = slices.DeleteFunc(timeSeries, func(ts prompb.TimeSeries) bool {
if filter != nil && filter(ts) { if filter != nil && filter(ts) {
//fmt.Println("deleteing")
if len(ts.Samples) > 0 { if len(ts.Samples) > 0 {
droppedSamples++ droppedSamples++
} }
@ -1782,13 +1779,8 @@ func buildTimeSeries(timeSeries []prompb.TimeSeries, filter func(prompb.TimeSeri
lowest = ts.Histograms[0].Timestamp lowest = ts.Histograms[0].Timestamp
} }
return false return false
// Move the current element to the write position and increment the write pointer
//timeSeries[keepIdx] = timeSeries[i]
//keepIdx++
}) })
//timeSeries = timeSeries[:keepIdx]
//fmt.Println("timeseries: ", timeSeries)
return highest, lowest, timeSeries, droppedSamples, droppedExemplars, droppedHistograms return highest, lowest, timeSeries, droppedSamples, droppedExemplars, droppedHistograms
} }