graphite

README

Graphite

The Graphite data format translates graphite dot buckets directly into telegraf measurement names, with a single value field, and without any tags. By default, the separator is left as ., but this can be changed using the separator argument. For more advanced options, Telegraf supports specifying templates to translate graphite buckets into Telegraf metrics.

Configuration

[[inputs.exec]]
  ## Commands array
  commands = ["/tmp/test.sh", "/usr/bin/mycollector --foo=bar"]

  ## measurement name suffix (for separating different commands)
  name_suffix = "_mycollector"

  ## Data format to consume.
  ## Each data format has its own unique set of configuration options, read
  ## more about them here:
  ## https://gitee.com/zhimiao/qiansi-telegraf/blob/master/docs/DATA_FORMATS_INPUT.md
  data_format = "graphite"

  ## This string will be used to join the matched values.
  separator = "_"

  ## 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. There can be only one default template.
  ## Templates support below format:
  ## 1. filter + template
  ## 2. filter + template + extra tag(s)
  ## 3. filter + template with field key
  ## 4. default template
  templates = [
    "*.app env.service.resource.measurement",
    "stats.* .host.measurement* region=eu-east,agent=sensu",
    "stats2.* .host.measurement.field",
    "measurement*"
  ]

templates

Consult the Template Patterns documentation for details.

Documentation

Index

• Constants
• Variables
• type Config
  • func (c *Config) Validate() error
• type GraphiteParser
  • func NewGraphiteParser(separator string, templates []string, defaultTags map[string]string) (*GraphiteParser, error)
  • func (p *GraphiteParser) ApplyTemplate(line string) (string, map[string]string, string, error)
  • func (p *GraphiteParser) Parse(buf []byte) ([]telegraf.Metric, error)
  • func (p *GraphiteParser) ParseLine(line string) (telegraf.Metric, error)
  • func (p *GraphiteParser) SetDefaultTags(tags map[string]string)

Constants

const (
	// DefaultSeparator is the default join character to use when joining multiple
	// measurement parts in a template.
	DefaultSeparator = "."
)

Variables

var (
	MinDate = time.Date(1901, 12, 13, 0, 0, 0, 0, time.UTC)
	MaxDate = time.Date(2038, 1, 19, 0, 0, 0, 0, time.UTC)
)

Minimum and maximum supported dates for timestamps.

Types

type Config

type Config struct {
	Separator string
	Templates []string
}

Config represents the configuration for Graphite endpoints.

func (*Config) Validate

func (c *Config) Validate() error

Validate validates the config's templates and tags.

type GraphiteParser

type GraphiteParser struct {
	Separator   string
	Templates   []string
	DefaultTags map[string]string
	// contains filtered or unexported fields
}

Parser encapsulates a Graphite Parser.

func NewGraphiteParser

func NewGraphiteParser(
	separator string,
	templates []string,
	defaultTags map[string]string,
) (*GraphiteParser, error)

func (*GraphiteParser) ApplyTemplate

func (p *GraphiteParser) ApplyTemplate(line string) (string, map[string]string, string, error)

ApplyTemplate extracts the template fields from the given line and returns the measurement name and tags.

func (*GraphiteParser) Parse

func (p *GraphiteParser) Parse(buf []byte) ([]telegraf.Metric, error)

func (*GraphiteParser) ParseLine

func (p *GraphiteParser) ParseLine(line string) (telegraf.Metric, error)

Parse performs Graphite parsing of a single line.

func (*GraphiteParser) SetDefaultTags

func (p *GraphiteParser) SetDefaultTags(tags map[string]string)