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://github.com/influxdata/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
• type Handler
• type MetricHandler
  • func NewMetricHandler() *MetricHandler
  • func (h *MetricHandler) AddBool(key []byte, value []byte)
  • func (h *MetricHandler) AddFloat(key []byte, value []byte)
  • func (h *MetricHandler) AddInt(key []byte, value []byte)
  • func (h *MetricHandler) AddString(key []byte, value []byte)
  • func (h *MetricHandler) AddTag(key []byte, value []byte)
  • func (h *MetricHandler) AddUint(key []byte, value []byte)
  • func (h *MetricHandler) Metric() (telegraf.Metric, error)
  • func (h *MetricHandler) Reset()
  • func (h *MetricHandler) SetMeasurement(name []byte)
  • func (h *MetricHandler) SetTimeFunc(f metric.TimeFunc)
  • func (h *MetricHandler) SetTimePrecision(precision time.Duration)
  • func (h *MetricHandler) SetTimestamp(tm []byte)
• type ParseError
  • func (e *ParseError) Error() string
• type Parser
  • func NewParser(handler *MetricHandler) *Parser
  • func NewSeriesParser(handler *MetricHandler) *Parser
  • func (m Parser) Err() 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)

Constants

const LineProtocol_en_align int = 196

const LineProtocol_en_discard_line int = 195

const LineProtocol_en_main int = 1

const LineProtocol_en_series int = 199

const LineProtocol_error int = 0

const LineProtocol_first_final int = 206

const LineProtocol_start int = 1

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")
)

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

Functions

func NewMachine

func NewMachine(handler Handler) *machine

func NewSeriesMachine

func NewSeriesMachine(handler Handler) *machine

Types

type Handler

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

type MetricHandler

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

func NewMetricHandler

func NewMetricHandler() *MetricHandler

func (*MetricHandler) AddBool

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

func (*MetricHandler) AddFloat

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

func (*MetricHandler) AddInt

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

func (*MetricHandler) AddString

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

func (*MetricHandler) AddTag

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

func (*MetricHandler) AddUint

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

func (*MetricHandler) Metric

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

func (*MetricHandler) Reset

func (h *MetricHandler) Reset()

func (*MetricHandler) SetMeasurement

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

func (*MetricHandler) SetTimeFunc

func (h *MetricHandler) SetTimeFunc(f metric.TimeFunc)

func (*MetricHandler) SetTimePrecision

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

func (*MetricHandler) SetTimestamp

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

type ParseError

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

func (*ParseError) Error

func (e *ParseError) Error() string

type Parser

type Parser struct {
	DefaultTags map[string]string

	sync.Mutex
	// contains filtered or unexported fields
}

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) Err

func (m Parser) Err() error

Err returns the error that occurred on the last call to ParseLine. If the result is nil, then the line was parsed successfully.

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 position into the input.

func (Parser) SetData

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

func (*Parser) SetDefaultTags

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