wavefront

README

Wavefront Parser Plugin

Wavefront Data Format is metrics are parsed directly into Telegraf metrics. For more information about the Wavefront Data Format see here.

Configuration

[[inputs.file]]
  files = ["example"]

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

There are no additional configuration options for Wavefront Data Format line-protocol.

Documentation

Index

• Constants
• Variables
• type ElementParser
  • func NewWavefrontElements() []ElementParser
• type LoopedParser
• type NameParser
• type Point
• type PointParser
  • func NewPointParser(parent *WavefrontParser) *PointParser
  • func (p *PointParser) Parse(buf []byte) ([]telegraf.Metric, error)
• type PointScanner
  • func NewScanner(r io.Reader) *PointScanner
  • func (s *PointScanner) Scan() (Token, string)
• type TagParser
• type TimestampParser
• type Token
• type ValueParser
• type WavefrontParser
  • func NewWavefrontParser(defaultTags map[string]string) *WavefrontParser
  • func (p *WavefrontParser) Parse(buf []byte) ([]telegraf.Metric, error)
  • func (p *WavefrontParser) ParseLine(line string) (telegraf.Metric, error)
  • func (p *WavefrontParser) SetDefaultTags(tags map[string]string)
• type WhiteSpaceParser

Constants

const MaxBufferSize = 2

Variables

var (
	ErrEOF              = errors.New("EOF")
	ErrInvalidTimestamp = errors.New("invalid timestamp")
)

Types

type ElementParser

type ElementParser interface {
	// contains filtered or unexported methods
}

func NewWavefrontElements

func NewWavefrontElements() []ElementParser

NewWavefrontElements returns a slice of ElementParser's for the Graphite format

type LoopedParser

type LoopedParser struct {
	// contains filtered or unexported fields
}

type NameParser

type NameParser struct{}

type Point

type Point struct {
	Name      string
	Value     string
	Timestamp int64
	Source    string
	Tags      map[string]string
}

type PointParser

type PointParser struct {
	Elements []ElementParser
	// contains filtered or unexported fields
}

PointParser is a thread-unsafe parser and must be kept in a pool.

func NewPointParser

func NewPointParser(parent *WavefrontParser) *PointParser

func (*PointParser) Parse

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

type PointScanner

type PointScanner struct {
	// contains filtered or unexported fields
}

Lexical Point Scanner

func NewScanner

func NewScanner(r io.Reader) *PointScanner

func (*PointScanner) Scan

func (s *PointScanner) Scan() (Token, string)

Scan returns the next token and literal value.

type TagParser

type TagParser struct{}

type TimestampParser

type TimestampParser struct {
	// contains filtered or unexported fields
}

type Token

type Token int

const (
	// Special tokens
	Illegal Token = iota
	EOF
	Ws

	Letter // metric name, source/point tags
	Number
	MinusSign
	Underscore
	Dot
	Slash
	Backslash
	Comma
	Delta

	// Misc characters
	Quotes
	Equals
	Newline
)

type ValueParser

type ValueParser struct{}

type WavefrontParser

type WavefrontParser struct {
	Log telegraf.Logger `toml:"-"`
	// contains filtered or unexported fields
}

func NewWavefrontParser

func NewWavefrontParser(defaultTags map[string]string) *WavefrontParser

func (*WavefrontParser) Parse

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

func (*WavefrontParser) ParseLine

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

func (*WavefrontParser) SetDefaultTags

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

type WhiteSpaceParser

type WhiteSpaceParser struct {
	// contains filtered or unexported fields
}