influxdb

Documentation

Index

• func Meta() libtsdb.Meta
• type Encoder
  • func NewEncoder() *Encoder
  • func (e *Encoder) WritePointDoubleTagged(p *pb.PointDoubleTagged)
  • func (e *Encoder) WritePointIntTagged(p *pb.PointIntTagged)
  • func (e *Encoder) WriteSeriesDoubleTagged(p *pb.SeriesDoubleTagged)
  • func (e *Encoder) WriteSeriesIntTagged(p *pb.SeriesIntTagged)

Functions

func Meta

func Meta() libtsdb.Meta

Types

type Encoder

type Encoder struct {
	bytesutil.Buffer
	// DefaultField is used when encoding single field series, which is the case for most TSDB but not InfluxDB
	// other tsdb (name, tags, value, ts)     : cpu.usage host=i7szx,dc=us-east 1.0 1359788400000
	// influxdb (name, tags, field=value, ts) : cpu.usage host=i7szx,dc=us-east v=1.0 1359788400000
	DefaultField string
}

Encoders encodes points with tags into InfluxDB's line protocol, it ONLY has a single field called v

ref https://github.com/influxdata/influxdb/blob/master/models/points.go#L2267 appendField

func NewEncoder

func NewEncoder() *Encoder

func (*Encoder) WritePointDoubleTagged

func (e *Encoder) WritePointDoubleTagged(p *pb.PointDoubleTagged)

func (*Encoder) WritePointIntTagged

func (e *Encoder) WritePointIntTagged(p *pb.PointIntTagged)

temperature,machine=unit42,type=assembly internal=32,external=100 1434055562000000035

func (*Encoder) WriteSeriesDoubleTagged

func (e *Encoder) WriteSeriesDoubleTagged(p *pb.SeriesDoubleTagged)

func (*Encoder) WriteSeriesIntTagged

func (e *Encoder) WriteSeriesIntTagged(p *pb.SeriesIntTagged)