influxif

Documentation

Index

• type InfluxConfig
• type InfluxIf
  • func NewClient(conf InfluxConfig) (*InfluxIf, error)
  • func (inf *InfluxIf) Close()
  • func (inf *InfluxIf) SyncDatabase(data []thingsif.DbMessage) error
  • func (inf *InfluxIf) WriteStbToDatabase(data *stbsource.StbWeather) error
  • func (inf *InfluxIf) WriteToDatabase(data *thingsif.Message) error

Types

type InfluxConfig

type InfluxConfig struct {
	HostAddress string
	Database    string
	Username    string
	Password    string
}

type InfluxIf

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

func NewClient

func NewClient(conf InfluxConfig) (*InfluxIf, error)

func (*InfluxIf) Close

func (inf *InfluxIf) Close()

func (*InfluxIf) SyncDatabase

func (inf *InfluxIf) SyncDatabase(data []thingsif.DbMessage) error

func (*InfluxIf) WriteStbToDatabase

func (inf *InfluxIf) WriteStbToDatabase(data *stbsource.StbWeather) error

func (*InfluxIf) WriteToDatabase

func (inf *InfluxIf) WriteToDatabase(data *thingsif.Message) error