github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2024-12-31 15:06:26 +00:00
Code Issues Projects Releases Packages Wiki Activity

wip

Browse source
This commit is contained in:
Aliaksandr Valialkin 2024-05-10 15:32:51 +02:00
parent 86942cb46c
commit 0dd32f5144
No known key found for this signature in database
GPG key ID: 52C003EE2BCDB9EB
1 changed files with 22 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
lib/logstorage/stats_uniq_values.go
View file

@ -2,7 +2,6 @@ package logstorage
import ( import (
"slices" "slices"
"sort"
"strconv" "strconv"
"strings" "strings"
"unsafe" "unsafe"
@ -188,7 +187,7 @@ func (sup *statsUniqValuesProcessor) finalizeStats() string {
for k := range sup.m { for k := range sup.m {
items = append(items, k) items = append(items, k)
} }
sort.Strings(items) slices.SortFunc(items, compareValues)
// Marshal items into JSON array. // Marshal items into JSON array.
@ -212,6 +211,27 @@ func (sup *statsUniqValuesProcessor) finalizeStats() string {
return bytesutil.ToUnsafeString(b) return bytesutil.ToUnsafeString(b)
} }
func compareValues(a, b string) int {
fA, okA := tryParseFloat64(a)
fB, okB := tryParseFloat64(b)
if okA && okB {
if fA == fB {
return 0
}
if fA < fB {
return -1
}
return 1
}
if okA {
return -1
}
if okB {
return 1
}
return strings.Compare(a, b)
}
func parseStatsUniqValues(lex *lexer) (*statsUniqValues, error) { func parseStatsUniqValues(lex *lexer) (*statsUniqValues, error) {
fields, err := parseFieldNamesForStatsFunc(lex, "uniq_values") fields, err := parseFieldNamesForStatsFunc(lex, "uniq_values")
if err != nil { if err != nil {