github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2024-11-21 14:44:00 +00:00
Code Issues Projects Releases Packages Wiki Activity

lib/protoparser: metrics renaming: vm_protoparser_<type>_* -> vm_protoparser_*{type="<type>"}

Browse source 
This should improve composability of these metrics in PromQL queries
This commit is contained in:
Aliaksandr Valialkin 2020-02-28 20:19:35 +02:00
parent 0eed71c7f4
commit 6a1aab88fd
6 changed files with 20 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
lib/protoparser/graphite/streamparser.go
View file

@ -100,9 +100,9 @@ func (ctx *streamContext) reset() {
}
var (
readCalls = metrics.NewCounter(`vm_protoparser_graphite_read_calls_total`)
readErrors = metrics.NewCounter(`vm_protoparser_graphite_read_errors_total`)
rowsRead = metrics.NewCounter(`vm_protoparser_graphite_rows_read_total`)
readCalls = metrics.NewCounter(`vm_protoparser_read_calls_total{type="graphite"}`)
readErrors = metrics.NewCounter(`vm_protoparser_read_errors_total{type="graphite"}`)
rowsRead = metrics.NewCounter(`vm_protoparser_rows_read_total{type="graphite"}`)
)
func getStreamContext() *streamContext {

6
lib/protoparser/influx/streamparser.go
View file

@ -97,9 +97,9 @@ func (ctx *streamContext) Read(r io.Reader, tsMultiplier int64) bool {
}
var (
readCalls = metrics.NewCounter(`vm_protoparser_influx_read_calls_total`)
readErrors = metrics.NewCounter(`vm_protoparser_influx_read_errors_total`)
rowsRead = metrics.NewCounter(`vm_protoparser_influx_rows_read_total`)
readCalls = metrics.NewCounter(`vm_protoparser_read_calls_total{type="influx"}`)
readErrors = metrics.NewCounter(`vm_protoparser_read_errors_total{type="influx"}`)
rowsRead = metrics.NewCounter(`vm_protoparser_rows_read_total{type="influx"}`)
)
type streamContext struct {

6
lib/protoparser/opentsdb/streamparser.go
View file

@ -98,9 +98,9 @@ func (ctx *streamContext) reset() {
}
var (
readCalls = metrics.NewCounter(`vm_protoparser_opentsdb_read_calls_total`)
readErrors = metrics.NewCounter(`vm_protoparser_opentsdb_read_errors_total`)
rowsRead = metrics.NewCounter(`vm_protoparser_opentsdb_rows_read_total`)
readCalls = metrics.NewCounter(`vm_protoparser_read_calls_total{type="opentsdb"}`)
readErrors = metrics.NewCounter(`vm_protoparser_read_errors_total{type="opentsdb"}`)
rowsRead = metrics.NewCounter(`vm_protoparser_rows_read_total{type="opentsdb"}`)
)
func getStreamContext() *streamContext {

8
lib/protoparser/opentsdbhttp/streamparser.go
View file

@ -96,10 +96,10 @@ func (ctx *streamContext) reset() {
}
var (
readCalls = metrics.NewCounter(`vm_protoparser_opentsdbhttp_read_calls_total`)
readErrors = metrics.NewCounter(`vm_protoparser_opentsdbhttp_read_errors_total`)
rowsRead = metrics.NewCounter(`vm_protoparser_opentsdbhttp_rows_read_total`)
unmarshalErrors = metrics.NewCounter(`vm_protoparser_opentsdbhttp_unmarshal_errors_total`)
readCalls = metrics.NewCounter(`vm_protoparser_read_calls_total{type="opentsdbhttp"}`)
readErrors = metrics.NewCounter(`vm_protoparser_read_errors_total{type="opentsdbhttp"}`)
rowsRead = metrics.NewCounter(`vm_protoparser_rows_read_total{type="opentsdbhttp"}`)
unmarshalErrors = metrics.NewCounter(`vm_protoparser_unmarshal_errors_total{type="opentsdbhttp"}`)
)
func getStreamContext() *streamContext {

8
lib/protoparser/promremotewrite/streamparser.go
View file

@ -62,10 +62,10 @@ func (ctx *pushCtx) Read(r *http.Request) error {
}
var (
readCalls = metrics.NewCounter(`vm_protoparser_promremotewrite_read_calls_total`)
readErrors = metrics.NewCounter(`vm_protoparser_promremotewrite_read_errors_total`)
rowsRead = metrics.NewCounter(`vm_protoparser_promremotewrite_rows_read_total`)
unmarshalErrors = metrics.NewCounter(`vm_protoparser_promremotewrite_unmarshal_errors`)
readCalls = metrics.NewCounter(`vm_protoparser_read_calls_total{type="promremotewrite"}`)
readErrors = metrics.NewCounter(`vm_protoparser_read_errors_total{type="promremotewrite"}`)
rowsRead = metrics.NewCounter(`vm_protoparser_rows_read_total{type="promremotewrite"}`)
unmarshalErrors = metrics.NewCounter(`vm_protoparser_unmarshal_errors{type="promremotewrite"}`)
)
func getPushCtx() *pushCtx {

6
lib/protoparser/vmimport/streamparser.go
View file

@ -60,9 +60,9 @@ func (ctx *streamContext) Read(r io.Reader) bool {
}
var (
readCalls = metrics.NewCounter(`vm_protoparser_vmimport_read_calls_total`)
readErrors = metrics.NewCounter(`vm_protoparser_vmimport_read_errors_total`)
rowsRead = metrics.NewCounter(`vm_protoparser_vmimport_rows_read_total`)
readCalls = metrics.NewCounter(`vm_protoparser_read_calls_total{type="vmimport"}`)
readErrors = metrics.NewCounter(`vm_protoparser_read_errors_total{type="vmimport"}`)
rowsRead = metrics.NewCounter(`vm_protoparser_rows_read_total{type="vmimport"}`)
)
type streamContext struct {