influx

Documentation

Index

• func ParseStream(r io.Reader, isGzipped bool, precision, db string, ...) error
• type Field
• type Row
• type Rows
  • func (rs *Rows) Reset()
  • func (rs *Rows) Unmarshal(s string)
• type Tag

Functions

func ParseStream

func ParseStream(r io.Reader, isGzipped bool, precision, db string, callback func(db string, rows []Row) error) error

ParseStream parses r with the given args and calls callback for the parsed rows.

The callback can be called concurrently multiple times for streamed data from r.

callback shouldn't hold rows after returning.

Types

type Field

type Field struct {
	Key   string
	Value float64
}

Field represents influx field.

type Row

type Row struct {
	Measurement string
	Tags        []Tag
	Fields      []Field
	Timestamp   int64
}

Row is a single influx row.

type Rows

type Rows struct {
	Rows []Row
	// contains filtered or unexported fields
}

Rows contains parsed influx rows.

func (*Rows) Reset

func (rs *Rows) Reset()

Reset resets rs.

func (*Rows) Unmarshal

func (rs *Rows) Unmarshal(s string)

Unmarshal unmarshals influx line protocol rows from s.

See https://docs.influxdata.com/influxdb/v1.7/write_protocols/line_protocol_tutorial/

s shouldn't be modified when rs is in use.

type Tag

type Tag struct {
	Key   string
	Value string
}

Tag represents influx tag.