influx

README

InfluxDB Line Protocol

There are no additional configuration options for InfluxDB line protocol. The metrics are parsed directly into Telegraf metrics.

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://gitee.com/zhimiao/qiansi-telegraf/blob/master/docs/DATA_FORMATS_INPUT.md
  data_format = "influx"

Documentation

Index

• Constants
• Variables
• func NewMachine(handler Handler) *machine
• func NewSeriesMachine(handler Handler) *machine
• func NewStreamMachine(r io.Reader, handler Handler) *streamMachine
• type Handler
• type MetricHandler
  • func NewMetricHandler() *MetricHandler
  • func (h *MetricHandler) AddBool(key []byte, value []byte) error
  • func (h *MetricHandler) AddFloat(key []byte, value []byte) error
  • func (h *MetricHandler) AddInt(key []byte, value []byte) error
  • func (h *MetricHandler) AddString(key []byte, value []byte) error
  • func (h *MetricHandler) AddTag(key []byte, value []byte) error
  • func (h *MetricHandler) AddUint(key []byte, value []byte) error
  • func (h *MetricHandler) Metric() (telegraf.Metric, error)
  • func (h *MetricHandler) SetMeasurement(name []byte) error
  • func (h *MetricHandler) SetTimeFunc(f TimeFunc)
  • func (h *MetricHandler) SetTimePrecision(p time.Duration)
  • func (h *MetricHandler) SetTimestamp(tm []byte) error
• type ParseError
  • func (e *ParseError) Error() string
• type Parser
  • func NewParser(handler *MetricHandler) *Parser
  • func NewSeriesParser(handler *MetricHandler) *Parser
  • func (m Parser) Column() int
  • func (m Parser) LineNumber() int
  • func (m Parser) LineOffset() int
  • func (m Parser) Next() error
  • func (p *Parser) Parse(input []byte) ([]telegraf.Metric, error)
  • func (p *Parser) ParseLine(line string) (telegraf.Metric, error)
  • func (m Parser) Position() int
  • func (m Parser) SetData(data []byte)
  • func (p *Parser) SetDefaultTags(tags map[string]string)
  • func (h *Parser) SetTimeFunc(f TimeFunc)
• type StreamParser
  • func NewStreamParser(r io.Reader) *StreamParser
  • func (p *StreamParser) Column() int
  • func (p *StreamParser) LineNumber() int
  • func (p *StreamParser) LineOffset() int
  • func (p *StreamParser) LineText() string
  • func (p *StreamParser) Next() (telegraf.Metric, error)
  • func (p *StreamParser) Position() int
  • func (h *StreamParser) SetTimeFunc(f TimeFunc)
  • func (h *StreamParser) SetTimePrecision(u time.Duration)
• type TimeFunc

Constants

const LineProtocol_en_align int = 739

const LineProtocol_en_discard_line int = 257

const LineProtocol_en_main int = 269

const LineProtocol_en_series int = 260

const LineProtocol_error int = 0

const LineProtocol_first_final int = 269

const LineProtocol_start int = 269

Variables

var (
	ErrNameParse      = errors.New("expected measurement name")
	ErrFieldParse     = errors.New("expected field")
	ErrTagParse       = errors.New("expected tag")
	ErrTimestampParse = errors.New("expected timestamp")
	ErrParse          = errors.New("parse error")
	EOF               = errors.New("EOF")
)

var (
	ErrNoMetric = errors.New("no metric in line")
)

Functions

func NewMachine

func NewMachine(handler Handler) *machine

func NewSeriesMachine

func NewSeriesMachine(handler Handler) *machine

func NewStreamMachine

func NewStreamMachine(r io.Reader, handler Handler) *streamMachine

Types

type Handler

type Handler interface {
	SetMeasurement(name []byte) error
	AddTag(key []byte, value []byte) error
	AddInt(key []byte, value []byte) error
	AddUint(key []byte, value []byte) error
	AddFloat(key []byte, value []byte) error
	AddString(key []byte, value []byte) error
	AddBool(key []byte, value []byte) error
	SetTimestamp(tm []byte) error
}

type MetricHandler

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

MetricHandler implements the Handler interface and produces telegraf.Metric.

func NewMetricHandler

func NewMetricHandler() *MetricHandler

func (*MetricHandler) AddBool

func (h *MetricHandler) AddBool(key []byte, value []byte) error

func (*MetricHandler) AddFloat

func (h *MetricHandler) AddFloat(key []byte, value []byte) error

func (*MetricHandler) AddInt

func (h *MetricHandler) AddInt(key []byte, value []byte) error

func (*MetricHandler) AddString

func (h *MetricHandler) AddString(key []byte, value []byte) error

func (*MetricHandler) AddTag

func (h *MetricHandler) AddTag(key []byte, value []byte) error

func (*MetricHandler) AddUint

func (h *MetricHandler) AddUint(key []byte, value []byte) error

func (*MetricHandler) Metric

func (h *MetricHandler) Metric() (telegraf.Metric, error)

func (*MetricHandler) SetMeasurement

func (h *MetricHandler) SetMeasurement(name []byte) error

func (*MetricHandler) SetTimeFunc

func (h *MetricHandler) SetTimeFunc(f TimeFunc)

func (*MetricHandler) SetTimePrecision

func (h *MetricHandler) SetTimePrecision(p time.Duration)

func (*MetricHandler) SetTimestamp

func (h *MetricHandler) SetTimestamp(tm []byte) error

type ParseError

type ParseError struct {
	Offset     int
	LineOffset int
	LineNumber int
	Column     int
	// contains filtered or unexported fields
}

ParseError indicates a error in the parsing of the text.

func (*ParseError) Error

func (e *ParseError) Error() string

type Parser

type Parser struct {
	DefaultTags map[string]string

	sync.Mutex
	// contains filtered or unexported fields
}

Parser is an InfluxDB Line Protocol parser that implements the parsers.Parser interface.

func NewParser

func NewParser(handler *MetricHandler) *Parser

NewParser returns a Parser than accepts line protocol

func NewSeriesParser

func NewSeriesParser(handler *MetricHandler) *Parser

NewSeriesParser returns a Parser than accepts a measurement and tagset

func (Parser) Column

func (m Parser) Column() int

Column returns the current column.

func (Parser) LineNumber

func (m Parser) LineNumber() int

LineNumber returns the current line number. Lines are counted based on the regular expression `\r?\n`.

func (Parser) LineOffset

func (m Parser) LineOffset() int

LineOffset returns the byte offset of the current line.

func (Parser) Next

func (m Parser) Next() error

Next parses the next metric line and returns nil if it was successfully processed. If the line contains a syntax error an error is returned, otherwise if the end of file is reached before finding a metric line then EOF is returned.

func (*Parser) Parse

func (p *Parser) Parse(input []byte) ([]telegraf.Metric, error)

func (*Parser) ParseLine

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

func (Parser) Position

func (m Parser) Position() int

Position returns the current byte offset into the data.

func (Parser) SetData

func (m Parser) SetData(data []byte)

func (*Parser) SetDefaultTags

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

func (*Parser) SetTimeFunc

func (h *Parser) SetTimeFunc(f TimeFunc)

type StreamParser

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

StreamParser is an InfluxDB Line Protocol parser. It is not safe for concurrent use in multiple goroutines.

func NewStreamParser

func NewStreamParser(r io.Reader) *StreamParser

func (*StreamParser) Column

func (p *StreamParser) Column() int

Column returns the current column.

func (*StreamParser) LineNumber

func (p *StreamParser) LineNumber() int

LineNumber returns the current line number. Lines are counted based on the regular expression `\r?\n`.

func (*StreamParser) LineOffset

func (p *StreamParser) LineOffset() int

LineOffset returns the byte offset of the current line.

func (*StreamParser) LineText

func (p *StreamParser) LineText() string

LineText returns the text of the current line that has been parsed so far.

func (*StreamParser) Next

func (p *StreamParser) Next() (telegraf.Metric, error)

Next parses the next item from the stream. You can repeat calls to this function if it returns ParseError to get the next metric or error.

func (*StreamParser) Position

func (p *StreamParser) Position() int

Position returns the current byte offset into the data.

func (*StreamParser) SetTimeFunc

func (h *StreamParser) SetTimeFunc(f TimeFunc)

SetTimeFunc changes the function used to determine the time of metrics without a timestamp. The default TimeFunc is time.Now. Useful mostly for testing, or perhaps if you want all metrics to have the same timestamp.

func (*StreamParser) SetTimePrecision

func (h *StreamParser) SetTimePrecision(u time.Duration)

type TimeFunc

type TimeFunc func() time.Time