influx

Documentation

Index

• Variables
• func GenerateQueries(elements []model.QueriesRequestElement, timeDirection model.Direction) (query string, err error)
• type Client
• type Influx
  • func NewInflux(config configuration.Config) (influx *Influx, err error)
  • func (this *Influx) ExecuteQuery(db string, query string) (responseP *influxLib.Response, err error)
  • func (this *Influx) GetLatestValue(db string, pair RequestElement) (timeValuePair TimeValuePair, err error)
  • func (this *Influx) GetLatestValues(db string, pairs []RequestElement) (timeValuePairs []TimeValuePair, err error)
  • func (this *Influx) GetTags(db string, measurement string) (tagMap map[string][]string, err error)
• type RequestElement
• type TimeValuePair

Variables

var ErrInfluxConnection = errors.New("communication with InfluxDB failed")

var ErrNULL = errors.New("NULL response")

var ErrNotFound = errors.New("not found")

Functions

func GenerateQueries

func GenerateQueries(elements []model.QueriesRequestElement, timeDirection model.Direction) (query string, err error)

Types

type Client

type Client interface {
	Query(query influxLib.Query) (*influxLib.Response, error)
}

type Influx

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

func NewInflux

func NewInflux(config configuration.Config) (influx *Influx, err error)

func (*Influx) ExecuteQuery

func (this *Influx) ExecuteQuery(db string, query string) (responseP *influxLib.Response, err error)

func (*Influx) GetLatestValue

func (this *Influx) GetLatestValue(db string, pair RequestElement) (timeValuePair TimeValuePair, err error)

func (*Influx) GetLatestValues

func (this *Influx) GetLatestValues(db string, pairs []RequestElement) (timeValuePairs []TimeValuePair, err error)

func (*Influx) GetTags

func (this *Influx) GetTags(db string, measurement string) (tagMap map[string][]string, err error)

type RequestElement

type RequestElement struct {
	Measurement string  `json:"measurement"`
	ColumnName  string  `json:"columnName"`
	Math        *string `json:"math"`
}

type TimeValuePair

type TimeValuePair struct {
	Time  *string     `json:"time"`
	Value interface{} `json:"value"`
}