influx

Documentation

Index

• Constants
• Variables
• func Close()
• func Insert(measurement, id string, fields map[string]interface{}, ts time.Time)
• func Load() error
• func Open()
• func SetOptions(opts Options)
• func Store() error
• type Options
  • func Default() Options
  • func GetOptions() Options
  • func (options *Options) FromEnv()
  • func (options *Options) ToEnv() []string
• type Point
  • func Query(measurement, id, field, start, end, win, fn string) ([]Point, error)
  • func Rate(measurement, id, field, start, end, win string) ([]Point, error)

Constants

const ENV = "IOT_MASTER_INFLUXDB_"

Variables

var Reader api.QueryAPI

var Writer api.WriteAPI

Functions

func Close

func Close()

func Insert

func Insert(measurement, id string, fields map[string]interface{}, ts time.Time)

func Load

func Load() error

func Open

func Open()

func SetOptions

func SetOptions(opts Options)

func Store

func Store() error

Types

type Options

type Options struct {
	Url    string `yaml:"url"`
	Org    string `yaml:"org"`
	Bucket string `yaml:"bucket"`
	Token  string `yaml:"token"`
}

func Default

func Default() Options

func GetOptions

func GetOptions() Options

func (*Options) FromEnv

func (options *Options) FromEnv()

func (*Options) ToEnv

func (options *Options) ToEnv() []string

type Point

type Point struct {
	Value interface{} `json:"value"`
	Time  time.Time   `json:"time"`
}

func Query

func Query(measurement, id, field, start, end, win, fn string) ([]Point, error)

func Rate

func Rate(measurement, id, field, start, end, win string) ([]Point, error)