influx

Documentation

Index

• func LineProtocol(name string, tags map[string]string, fields map[string]interface{}, ...) (string, error)
• func Query(influxDBAddr, influxQl string, fns ...OptionsFn) (string, error)
• func Write(influxDBWriteAddr, line string, fns ...OptionsFn) (*http.Response, string, error)
• type Options
• type OptionsFn
  • func WithBasic(auth string) OptionsFn

Functions

func LineProtocol

func LineProtocol(name string, tags map[string]string, fields map[string]interface{}, t time.Time) (string, error)

LineProtocol format inputs to line protocol https://docs.influxdata.com/influxdb/v1.7/write_protocols/line_protocol_tutorial/

func Query

func Query(influxDBAddr, influxQl string, fns ...OptionsFn) (string, error)

Query execute influxQl (refer to https://docs.influxdata.com/influxdb/v1.7/query_language) influxDBAddr InfluxDB的连接地址， 例如http://localhost:8086, 注意：1. 右边没有/ 2. 右边不带其它path，例如/query等。 usage example: influx.Query(addr, ql, influx.WithBasic("username:password"))

func Write

func Write(influxDBWriteAddr, line string, fns ...OptionsFn) (*http.Response, string, error)

Write 写入打点值 refer https://github.com/DCSO/fluxline/blob/master/encoder.go usage example: influx.Write(addr, line, influx.WithBasic("username:password"))

Types

type Options

type Options struct {
	Basic string
}

type OptionsFn

type OptionsFn func(options *Options)

func WithBasic

func WithBasic(auth string) OptionsFn

WithBasic set basic auth, auth should be in format of username + ":" + password