fix running parsers
This commit is contained in:
parent
c0583675ce
commit
c67da98d32
|
|
@ -75,7 +75,7 @@ func (r *RunningParser) Init() error {
|
||||||
|
|
||||||
func (r *RunningParser) Parse(buf []byte, extra string) ([]telegraf.Metric, error) {
|
func (r *RunningParser) Parse(buf []byte, extra string) ([]telegraf.Metric, error) {
|
||||||
start := time.Now()
|
start := time.Now()
|
||||||
m, err := r.Parser.Parse(buf, "")
|
m, err := r.Parser.Parse(buf, extra)
|
||||||
elapsed := time.Since(start)
|
elapsed := time.Since(start)
|
||||||
r.ParseTime.Incr(elapsed.Nanoseconds())
|
r.ParseTime.Incr(elapsed.Nanoseconds())
|
||||||
r.MetricsParsed.Incr(int64(len(m)))
|
r.MetricsParsed.Incr(int64(len(m)))
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue