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

app/vmagent/{promremotewrite,vmimport}: remove unused functions InsertHandlerForReader()

Browse source 
Thanks to 1cfa183c2b , where the first such function has been removed
This commit is contained in:
Aliaksandr Valialkin 2023-01-23 22:30:30 -08:00
parent f7acdb13db
commit c496f06ca3
No known key found for this signature in database
GPG key ID: A72BEC6CD3D0DED1
2 changed files with 0 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
app/vmagent/promremotewrite/request_handler.go
View file

@ -1,7 +1,6 @@
package promremotewrite package promremotewrite
import ( import (
"io"
"net/http" "net/http"
"github.com/VictoriaMetrics/VictoriaMetrics/app/vmagent/common" "github.com/VictoriaMetrics/VictoriaMetrics/app/vmagent/common"
@ -33,13 +32,6 @@ func InsertHandler(at *auth.Token, req *http.Request) error {
}) })
} }
// InsertHandlerForReader processes metrics from given reader
func InsertHandlerForReader(at *auth.Token, r io.Reader) error {
return parser.ParseStream(r, func(tss []prompb.TimeSeries) error {
return insertRows(at, tss, nil)
})
}
func insertRows(at *auth.Token, timeseries []prompb.TimeSeries, extraLabels []prompbmarshal.Label) error { func insertRows(at *auth.Token, timeseries []prompb.TimeSeries, extraLabels []prompbmarshal.Label) error {
ctx := common.GetPushCtx() ctx := common.GetPushCtx()
defer common.PutPushCtx(ctx) defer common.PutPushCtx(ctx)

8
app/vmagent/vmimport/request_handler.go
View file

@ -1,7 +1,6 @@
package vmimport package vmimport
import ( import (
"io"
"net/http" "net/http"
"github.com/VictoriaMetrics/VictoriaMetrics/app/vmagent/common" "github.com/VictoriaMetrics/VictoriaMetrics/app/vmagent/common"
@ -36,13 +35,6 @@ func InsertHandler(at *auth.Token, req *http.Request) error {
}) })
} }
// InsertHandlerForReader processes metrics from given reader
func InsertHandlerForReader(r io.Reader, isGzipped bool) error {
return parser.ParseStream(r, isGzipped, func(rows []parser.Row) error {
return insertRows(nil, rows, nil)
})
}
func insertRows(at *auth.Token, rows []parser.Row, extraLabels []prompbmarshal.Label) error { func insertRows(at *auth.Token, rows []parser.Row, extraLabels []prompbmarshal.Label) error {
ctx := common.GetPushCtx() ctx := common.GetPushCtx()
defer common.PutPushCtx(ctx) defer common.PutPushCtx(ctx)