Return results in a stable order
This commit is contained in:
@@ -145,33 +145,6 @@ func Filter(series []*TimeSeriesData, n int, order string, aggFunc AggFunc) []*T
|
||||
return filteredSeries
|
||||
}
|
||||
|
||||
func SortBy(series []*TimeSeriesData, order string, aggFunc AggFunc) []*TimeSeriesData {
|
||||
aggregatedSeries := make([]TimeSeries, len(series))
|
||||
for i, s := range series {
|
||||
aggregatedSeries[i] = s.TS.GroupByRange(aggFunc)
|
||||
}
|
||||
|
||||
// Sort by aggregated value
|
||||
sort.Slice(series, func(i, j int) bool {
|
||||
if len(aggregatedSeries[i]) > 0 && len(aggregatedSeries[j]) > 0 {
|
||||
return *aggregatedSeries[i][0].Value < *aggregatedSeries[j][0].Value
|
||||
} else if len(aggregatedSeries[j]) > 0 {
|
||||
return true
|
||||
}
|
||||
return false
|
||||
})
|
||||
|
||||
if order == "desc" {
|
||||
reverseSeries := make([]*TimeSeriesData, len(series))
|
||||
for i := 0; i < len(series); i++ {
|
||||
reverseSeries[i] = series[len(series)-1-i]
|
||||
}
|
||||
series = reverseSeries
|
||||
}
|
||||
|
||||
return series
|
||||
}
|
||||
|
||||
func AggregateBy(series []*TimeSeriesData, interval time.Duration, aggFunc AggFunc) *TimeSeriesData {
|
||||
aggregatedSeries := NewTimeSeries()
|
||||
|
||||
|
||||
Reference in New Issue
Block a user