p17860254
/
categraf
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

exec plugin support prometheus

This commit is contained in:
Ulric Qin 2022-07-22 19:34:58 +08:00
parent a70c1fa24f
commit eb81b9b463
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
inputs/exec/exec.go
View File

@ -18,6 +18,7 @@ import (
"flashcat.cloud/categraf/parser" "flashcat.cloud/categraf/parser"
"flashcat.cloud/categraf/parser/falcon" "flashcat.cloud/categraf/parser/falcon"
"flashcat.cloud/categraf/parser/influx" "flashcat.cloud/categraf/parser/influx"
"flashcat.cloud/categraf/parser/prometheus"
"flashcat.cloud/categraf/pkg/cmdx" "flashcat.cloud/categraf/pkg/cmdx"
"flashcat.cloud/categraf/types" "flashcat.cloud/categraf/types"
"github.com/kballard/go-shellquote" "github.com/kballard/go-shellquote"
@ -66,6 +67,8 @@ func (e *Exec) Init() error {
e.Instances[i].parser = influx.NewParser() e.Instances[i].parser = influx.NewParser()
} else if e.Instances[i].DataFormat == "falcon" { } else if e.Instances[i].DataFormat == "falcon" {
e.Instances[i].parser = falcon.NewParser() e.Instances[i].parser = falcon.NewParser()
} else if e.Instances[i].DataFormat == "prometheus" {
e.Instances[i].parser = prometheus.NewParser("", map[string]string{}, nil, nil, nil)
} else { } else {
return fmt.Errorf("data_format(%s) not supported", e.Instances[i].DataFormat) return fmt.Errorf("data_format(%s) not supported", e.Instances[i].DataFormat)
} }