influxdb

Documentation

Index

• type InfluxDB
  • func (idc *InfluxDB) Close()
  • func (idc *InfluxDB) Get(cmd string) (res []client.Result, err error)
  • func (idc *InfluxDB) Init(c config.Config) error
  • func (idc *InfluxDB) ObjectCreated(obj event.Event)
  • func (idc *InfluxDB) ObjectDeleted(obj event.Event)
  • func (idc *InfluxDB) ObjectUpdated(obj event.Event)
  • func (idc *InfluxDB) RecordEventToInflux(e event.Event)
  • func (idc *InfluxDB) Write(measurement string, tags map[string]string, fields map[string]interface{}, ...)

Types

type InfluxDB

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

func (*InfluxDB) Close

func (idc *InfluxDB) Close()

func (*InfluxDB) Get

func (idc *InfluxDB) Get(cmd string) (res []client.Result, err error)

Get 对资源进行查询

func (*InfluxDB) Init

func (idc *InfluxDB) Init(c config.Config) error

func (*InfluxDB) ObjectCreated

func (idc *InfluxDB) ObjectCreated(obj event.Event)

func (*InfluxDB) ObjectDeleted

func (idc *InfluxDB) ObjectDeleted(obj event.Event)

func (*InfluxDB) ObjectUpdated

func (idc *InfluxDB) ObjectUpdated(obj event.Event)

func (*InfluxDB) RecordEventToInflux

func (idc *InfluxDB) RecordEventToInflux(e event.Event)

func (*InfluxDB) Write

func (idc *InfluxDB) Write(measurement string, tags map[string]string, fields map[string]interface{}, t time.Time)

Write 执行写入动作 会先判断连接状态