influxdb

Documentation

Index

• type InfluxDbClient
  • func NewClient(opts *InfluxdbOptions) *InfluxDbClient
  • func (i *InfluxDbClient) RunQuery(query string) (*api.QueryTableResult, error)
  • func (i *InfluxDbClient) SendToInfluxdb(measurement string, ts time.Time, tags map[string]string, ...)
• type InfluxdbOptions

Types

type InfluxDbClient

type InfluxDbClient struct {
	InfluxdbOptions
	// contains filtered or unexported fields
}

func NewClient

func NewClient(opts *InfluxdbOptions) *InfluxDbClient

func (*InfluxDbClient) RunQuery

func (i *InfluxDbClient) RunQuery(query string) (*api.QueryTableResult, error)

func (*InfluxDbClient) SendToInfluxdb

func (i *InfluxDbClient) SendToInfluxdb(measurement string, ts time.Time, tags map[string]string, fields map[string]interface{})

type InfluxdbOptions

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