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-06-05 03:10:32 +02:00
parent 238115a6e7
commit 827984faa2
No known key found for this signature in database
GPG key ID: 52C003EE2BCDB9EB
2 changed files with 18 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
lib/logstorage/block_result.go
View file

@ -4,6 +4,7 @@ import (
"math"
"slices"
"strconv"
"strings"
"sync/atomic"
"time"
"unsafe"
@ -1933,7 +1934,7 @@ func tryParseNumber(s string) (float64, bool) {
if ok {
return float64(bytes), true
}
if isNumberPrefix(s) {
if isLikelyNumber(s) {
f, err := strconv.ParseFloat(s, 64)
if err == nil {
return f, true
@ -1946,5 +1947,20 @@ func tryParseNumber(s string) (float64, bool) {
return 0, false
}
func isLikelyNumber(s string) bool {
if !isNumberPrefix(s) {
return false
}
if strings.Count(s, ".") > 1 {
// This is likely IP address
return false
}
if strings.IndexByte(s, ':') >= 0 || strings.Count(s, "-") > 2 {
// This is likely a timestamp
return false
}
return true
}
var nan = math.NaN()
var inf = math.Inf(1)

2
lib/logstorage/parser_test.go
View file

@ -496,7 +496,7 @@ func TestParseRangeFilter(t *testing.T) {
}
fr, ok := q.f.(*filterRange)
if !ok {
t.Fatalf("unexpected filter type; got %T; want *filterIPv4Range; filter: %s", q.f, q.f)
t.Fatalf("unexpected filter type; got %T; want *filterRange; filter: %s", q.f, q.f)
}
if fr.fieldName != fieldNameExpected {
t.Fatalf("unexpected fieldName; got %q; want %q", fr.fieldName, fieldNameExpected)