wavefront

package
v0.0.19 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 31, 2021 License: MIT Imports: 11 Imported by: 0

README

Wavefront

Wavefront Data Format is metrics are parsed directly into 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://github.com/circonus-labs/circonus-unified-agent/blob/master/docs/DATA_FORMATS_INPUT.md
  data_format = "wavefront"

Documentation

Index

Constants

View Source
const MaxBufferSize = 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 {
}

type LoopedParser

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

type NameParser

type NameParser struct{}

type Parser added in v0.0.12

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

func NewWavefrontParser

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

func (*Parser) Parse added in v0.0.12

func (p *Parser) Parse(buf []byte) ([]cua.Metric, error)

func (*Parser) ParseLine added in v0.0.12

func (p *Parser) ParseLine(line string) (cua.Metric, error)

func (*Parser) SetDefaultTags added in v0.0.12

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

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 *Parser) *PointParser

func (*PointParser) Parse

func (p *PointParser) Parse(buf []byte) ([]cua.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 WhiteSpaceParser

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL