influxdb

Documentation

Index

• type InfluxDB
  • func NewInfluxDB(cfg *viper.Viper, logger *logging.Logger) *InfluxDB
  • func (i *InfluxDB) GetValues(item item.Item) [][]interface{}
  • func (i *InfluxDB) OnValueChange(it item.Item, old string, new string)
  • func (i *InfluxDB) Watch(item item.Item)
• type Point

Types

type InfluxDB

type InfluxDB struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewInfluxDB

func NewInfluxDB(cfg *viper.Viper, logger *logging.Logger) *InfluxDB

NewInfluxDB returns a new instance of influxdb time series database. It implements the ObjectListener interface thus It will store the states objects monitored.

func (*InfluxDB) GetValues

func (i *InfluxDB) GetValues(item item.Item) [][]interface{}

func (*InfluxDB) OnValueChange

func (i *InfluxDB) OnValueChange(it item.Item, old string, new string)

func (*InfluxDB) Watch

func (i *InfluxDB) Watch(item item.Item)

type Point

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