allow measurement to be defined for logparser_grok plugin

influxdata · Jul 18, 2016 · 8c7edeb · 8c7edeb
1 parent 1d9745e
commit 8c7edeb
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/plugins/inputs/logparser/grok/grok.go b/plugins/inputs/logparser/grok/grok.go
@@ -56,6 +56,7 @@ type Parser struct {
  Patterns []string
  CustomPatterns string
  CustomPatternFiles []string
+ Measurement string
 
  // typeMap is a map of patterns -> capture name -> modifier,
  // ie, {
@@ -114,6 +115,10 @@ func (p *Parser) Compile() error {
  p.addCustomPatterns(scanner)
  }
 
+ if p.Measurement == "" {
+ p.Measurement = "logparser_grok"
+ }
+
  return p.compileCustomPatterns()
 }
 
@@ -215,7 +220,7 @@ func (p *Parser) ParseLine(line string) (telegraf.Metric, error) {
  }
  }
 
- return telegraf.NewMetric("logparser_grok", tags, fields, p.tsModder.tsMod(timestamp))
+ return telegraf.NewMetric(p.Measurement, tags, fields, p.tsModder.tsMod(timestamp))
 }
 
 func (p *Parser) addCustomPatterns(scanner *bufio.Scanner) {