README
¶
Wavefront
Wavefront Data Format is metrics are parsed directly into Telegraf metrics. For more information about the Wavefront Data Format see here.
Configuration
There are no additional configuration options for Wavefront Data Format line-protocol.
[[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://gitee.com/zhimiao/qiansi-telegraf/blob/master/docs/DATA_FORMATS_INPUT.md
data_format = "wavefront"
Documentation
¶
Index ¶
Constants ¶
View Source
const MAX_BUFFER_SIZE = 2
Variables ¶
View Source
var ( ErrEOF = errors.New("EOF") ErrInvalidTimestamp = errors.New("Invalid timestamp") )
Functions ¶
This section is empty.
Types ¶
type ElementParser ¶
type ElementParser interface {
// contains filtered or unexported methods
}
Interface for parsing line elements.
func NewWavefrontElements ¶
func NewWavefrontElements() []ElementParser
Returns a slice of ElementParser's for the Graphite format
type LiteralParser ¶
type LiteralParser struct {
// contains filtered or unexported fields
}
type LoopedParser ¶
type LoopedParser struct {
// contains filtered or unexported fields
}
type NameParser ¶
type NameParser struct{}
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 TimestampParser ¶
type TimestampParser struct {
// contains filtered or unexported fields
}
type ValueParser ¶
type ValueParser struct{}
type WavefrontParser ¶
type WavefrontParser struct {
// 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
}
Source Files
Click to show internal directories.
Click to hide internal directories.