Kiu/VictoriaMetrics
Kiu/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2024-12-15 16:30:55 +01:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

lib/protoparser: properly update vm_protoparser_rows_read_total{type="promscrape"} metric

Browse Source
This commit is contained in:
Aliaksandr Valialkin 2020-07-14 12:15:25 +03:00
parent a5e713b6e0
commit a4c96d9e6d
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
lib/protoparser/prometheus/parser.go
View File

@ -150,18 +150,18 @@ func (r *Row) unmarshal(s string, tagsPool []Tag, noEscapes bool) ([]Tag, error)
var rowsReadScrape = metrics.NewCounter(`vm_protoparser_rows_read_total{type="promscrape"}`) var rowsReadScrape = metrics.NewCounter(`vm_protoparser_rows_read_total{type="promscrape"}`)
func unmarshalRows(dst []Row, s string, tagsPool []Tag, noEscapes bool, errLogger func(s string)) ([]Row, []Tag) { func unmarshalRows(dst []Row, s string, tagsPool []Tag, noEscapes bool, errLogger func(s string)) ([]Row, []Tag) {
dstLen := len(dst)
for len(s) > 0 { for len(s) > 0 {
n := strings.IndexByte(s, '\n') n := strings.IndexByte(s, '\n')
if n < 0 { if n < 0 {
// The last line. // The last line.
dst, tagsPool = unmarshalRow(dst, s, tagsPool, noEscapes, errLogger) dst, tagsPool = unmarshalRow(dst, s, tagsPool, noEscapes, errLogger)
break break
} else {
dst, tagsPool = unmarshalRow(dst, s[:n], tagsPool, noEscapes, errLogger)
s = s[n+1:]
} }
dst, tagsPool = unmarshalRow(dst, s[:n], tagsPool, noEscapes, errLogger)
s = s[n+1:]
} }
rowsReadScrape.Add(len(dst)) rowsReadScrape.Add(len(dst) - dstLen)
return dst, tagsPool return dst, tagsPool
} }