Removed the Tags capability from the graphite parser and modified the exe description...

internal/encoding/graphite/config.go

@@ -3,8 +3,6 @@ package graphite
 import (
 	"fmt"
 	"strings"
-
-	"github.com/influxdata/influxdb/models"
 )
 
 const (
@@ -16,30 +14,15 @@ const (
 // Config represents the configuration for Graphite endpoints.
 type Config struct {
 	Separator string
-	Tags      []string
 	Templates []string
 }
 
-// DefaultTags returns the config's tags.
-func (c *Config) DefaultTags() models.Tags {
-	tags := models.Tags{}
-	for _, t := range c.Tags {
-		parts := strings.Split(t, "=")
-		tags[parts[0]] = parts[1]
-	}
-	return tags
-}
-
 // Validate validates the config's templates and tags.
 func (c *Config) Validate() error {
 	if err := c.validateTemplates(); err != nil {
 		return err
 	}
 
-	if err := c.validateTags(); err != nil {
-		return err
-	}
-
 	return nil
 }
 
@@ -110,15 +93,6 @@ func (c *Config) validateTemplates() error {
 	return nil
 }
 
-func (c *Config) validateTags() error {
-	for _, t := range c.Tags {
-		if err := c.validateTag(t); err != nil {
-			return err
-		}
-	}
-	return nil
-}
-
 func (c *Config) validateTemplate(template string) error {
 	hasMeasurement := false
 	for _, p := range strings.Split(template, ".") {

internal/encoding/graphite/parser.go

@@ -35,14 +35,12 @@ func init() {
 // Parser encapsulates a Graphite Parser.
 type Parser struct {
 	matcher *matcher
-	tags    models.Tags
 }
 
 // Options are configurable values that can be provided to a Parser
 type Options struct {
 	Separator string
 	Templates []string
-	DefaultTags models.Tags
 }
 
 // NewParserWithOptions returns a graphite parser using the given options
@@ -84,15 +82,14 @@ func NewParserWithOptions(options Options) (*Parser, error) {
 		}
 		matcher.Add(filter, tmpl)
 	}
-	return &Parser{matcher: matcher, tags: options.DefaultTags}, nil
+	return &Parser{matcher: matcher}, nil
 }
 
 // NewParser returns a GraphiteParser instance.
-func NewParser(templates []string, defaultTags models.Tags) (*Parser, error) {
+func NewParser(templates []string) (*Parser, error) {
 	return NewParserWithOptions(
 		Options{
 			Templates: templates,
-			DefaultTags: defaultTags,
 			Separator: DefaultSeparator,
 		})
 }
@@ -182,12 +179,6 @@ func (p *Parser) Parse(line string) (telegraf.Metric, error) {
 		}
 	}
 
-	// Set the default tags on the point if they are not already set
-	for k, v := range p.tags {
-		if _, ok := tags[k]; !ok {
-			tags[k] = v
-		}
-	}
 	return telegraf.NewMetric(measurement, tags, fieldValues, timestamp)
 }
 
@@ -202,12 +193,7 @@ func (p *Parser) ApplyTemplate(line string) (string, map[string]string, string,
 	// decode the name and tags
 	template := p.matcher.Match(fields[0])
 	name, tags, field, err := template.Apply(fields[0])
-	// Set the default tags on the point if they are not already set
+
-	for k, v := range p.tags {
-		if _, ok := tags[k]; !ok {
-			tags[k] = v
-		}
-	}
 	return name, tags, field, err
 }
 

plugins/inputs/exec/README.md

@@ -44,19 +44,15 @@ and strings will be ignored.
   ### If matching multiple measurement files, this string will be used to join the matched values.
   #separator = "."
 
-  ### Default tags that will be added to all metrics.  These can be overridden at the template level
-  ### or by tags extracted from metric
-  #tags = ["region=north-east", "zone=1c"]
-
   ### Each template line requires a template pattern.  It can have an optional
   ### filter before the template and separated by spaces.  It can also have optional extra
   ### tags following the template.  Multiple tags should be separated by commas and no spaces
   ### similar to the line protocol format.  The can be only one default template.
   ### Templates support below format:
-  ### filter + template
+  ### 1. filter + template
-  ### filter + template + extra tag
+  ### 2. filter + template + extra tag
-  ### filter + template with field key
+  ### 3. filter + template with field key
-  ### default template. Ignore the first graphite component "servers"
+  ### 4. default template
   #templates = [
   #  "*.app env.service.resource.measurement",
   #  "stats.* .host.measurement* region=us-west,agent=sensu",
@@ -149,19 +145,15 @@ We can also change the data_format to "graphite" to use the metrics collecting s
   ### If matching multiple measurement files, this string will be used to join the matched values.
   separator = "."
 
-  ### Default tags that will be added to all metrics.  These can be overridden at the template level
-  ### or by tags extracted from metric
-  tags = ["region=north-east", "zone=1c"]
-
   ### Each template line requires a template pattern.  It can have an optional
   ### filter before the template and separated by spaces.  It can also have optional extra
   ### tags following the template.  Multiple tags should be separated by commas and no spaces
   ### similar to the line protocol format.  The can be only one default template.
   ### Templates support below format:
-  ### filter + template
+  ### 1. filter + template
-  ### filter + template + extra tag
+  ### 2. filter + template + extra tag
-  ### filter + template with field key
+  ### 3. filter + template with field key
-  ### default template. Ignore the first graphite component "servers"
+  ### 4. default template
   templates = [
     "*.app env.service.resource.measurement",
     "stats.* .host.measurement* region=us-west,agent=sensu",

plugins/inputs/exec/config.go

@@ -4,12 +4,6 @@ import (
 	"github.com/influxdata/telegraf/internal/encoding/graphite"
 )
 
-const (
-	// DefaultSeparator is the default join character to use when joining multiple
-	// measurment parts in a template.
-	DefaultSeparator = "."
-)
-
 // Config represents the configuration for Graphite endpoints.
 type Config struct {
 	Commands []string
@@ -17,21 +11,15 @@ type Config struct {
 }
 
 // New Config instance.
-func NewConfig(commands, tags, templates []string, separator string) *Config {
+func NewConfig(commands, templates []string, separator string) *Config {
 	c := &Config{}
+	if separator == "" {
+		separator = graphite.DefaultSeparator
+	}
+
 	c.Commands = commands
-	c.Tags = tags
 	c.Templates = templates
 	c.Separator = separator
+
 	return c
 }
-
-// WithDefaults takes the given config and returns a new config with any required
-// default values set.
-func (c *Config) WithDefaults() *Config {
-	d := *c
-	if d.Separator == "" {
-		d.Separator = DefaultSeparator
-	}
-	return &d
-}

plugins/inputs/exec/exec.go

@@ -32,19 +32,15 @@ const sampleConfig = `
   ### If matching multiple measurement files, this string will be used to join the matched values.
   separator = "."
 
-  ### Default tags that will be added to all metrics.  These can be overridden at the template level
-  ### or by tags extracted from metric
-  tags = ["region=north-east", "zone=1c"]
-
   ### Each template line requires a template pattern.  It can have an optional
   ### filter before the template and separated by spaces.  It can also have optional extra
   ### tags following the template.  Multiple tags should be separated by commas and no spaces
   ### similar to the line protocol format.  The can be only one default template.
   ### Templates support below format:
-  ### filter + template
+  ### 1. filter + template
-  ### filter + template + extra tag
+  ### 2. filter + template + extra tag
-  ### filter + template with field key
+  ### 3. filter + template with field key
-  ### default template. Ignore the first graphite component "servers"
+  ### 4. default template
   templates = [
     "*.app env.service.resource.measurement",
     "stats.* .host.measurement* region=us-west,agent=sensu",
@@ -59,7 +55,6 @@ type Exec struct {
 	DataFormat string
 
 	Separator string
-	Tags      []string
 	Templates []string
 
 	encodingParser *encoding.Parser
@@ -125,8 +120,7 @@ func (e *Exec) initConfig() error {
 		e.Commands = []string{e.Command}
 	}
 
-	c := NewConfig(e.Commands, e.Tags, e.Templates, e.Separator)
+	c := NewConfig(e.Commands, e.Templates, e.Separator)
-	c.WithDefaults()
 	if err := c.Validate(); err != nil {
 		return fmt.Errorf("exec configuration is error: %s ", err.Error())
 
@@ -135,7 +129,6 @@ func (e *Exec) initConfig() error {
 
 	graphiteParser, err := graphite.NewParserWithOptions(graphite.Options{
 		Templates: e.config.Templates,
-		DefaultTags: e.config.DefaultTags(),
 		Separator: e.config.Separator})
 
 	if err != nil {
@@ -152,7 +145,7 @@ func (e *Exec) SampleConfig() string {
 }
 
 func (e *Exec) Description() string {
-	return "Read metrics from one or more commands that output graphite line protocol to stdout"
+	return "Read metrics from one or more commands that can output JSON, influx or graphite line protocol to stdout"
 }
 
 func (e *Exec) Gather(acc telegraf.Accumulator) error {