influxdb

Documentation

Index

• func NewInfluxdb(config *store.Config) store.Store
• type Influxdb
  • func (e *Influxdb) Close()
  • func (e *Influxdb) Connect(conf ...*store.Config)
  • func (e *Influxdb) GetInstance(conf ...*store.Config) influxdb2.Client
• type Query
  • func NewQuery(bucket string, loc ...string) *Query
  • func (e *Query) Build() string
  • func (e *Query) Order(order string) *Query
  • func (e *Query) Page(page, limit uint32) *Query
  • func (e *Query) Pivot(tz string) *Query
  • func (e *Query) Table(m string) *Query
  • func (e *Query) Tz(tz map[string]int64) *Query
  • func (e *Query) Where(field, value string) *Query

Functions

func NewInfluxdb

func NewInfluxdb(config *store.Config) store.Store

Types

type Influxdb

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

func (*Influxdb) Close

func (e *Influxdb) Close()

func (*Influxdb) Connect

func (e *Influxdb) Connect(conf ...*store.Config)

func (*Influxdb) GetInstance

func (e *Influxdb) GetInstance(conf ...*store.Config) influxdb2.Client

type Query

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

func NewQuery

func NewQuery(bucket string, loc ...string) *Query

func (*Query) Build

func (e *Query) Build() string

func (*Query) Order

func (e *Query) Order(order string) *Query

func (*Query) Page

func (e *Query) Page(page, limit uint32) *Query

func (*Query) Pivot

func (e *Query) Pivot(tz string) *Query

func (*Query) Table

func (e *Query) Table(m string) *Query

func (*Query) Tz

func (e *Query) Tz(tz map[string]int64) *Query

func (*Query) Where

func (e *Query) Where(field, value string) *Query