gxinfluxdb

Documentation

Overview

2018-10-23 21:46 package gxinfluxdb provides a InfluxDB driver

Index

• type BatchPoints
  • func NewBatchPoints(db, precision string) *BatchPoints
  • func (bp *BatchPoints) AddPoint(p *client.Point)
  • func (bp *BatchPoints) AddPoints(ps []*client.Point)
  • func (bp *BatchPoints) Clear()
  • func (bp *BatchPoints) Database() string
  • func (bp *BatchPoints) Points() []*client.Point
  • func (bp *BatchPoints) Precision() string
  • func (bp *BatchPoints) RetentionPolicy() string
  • func (bp *BatchPoints) SetDatabase(db string)
  • func (bp *BatchPoints) SetPrecision(p string) error
  • func (bp *BatchPoints) SetRetentionPolicy(rp string)
  • func (bp *BatchPoints) SetWriteConsistency(wc string)
  • func (bp *BatchPoints) Size() int
  • func (bp *BatchPoints) WriteConsistency() string
• type InfluxDBClient
  • func NewInfluxDBClient(host, user, password, db, precision string) (InfluxDBClient, error)
  • func (c InfluxDBClient) AddPoint(pt *client.Point)
  • func (c InfluxDBClient) AddPointData(table string, tags map[string]string, fields map[string]interface{}, ...) error
  • func (c InfluxDBClient) BatchPointSize() int
  • func (c InfluxDBClient) Close() error
  • func (c InfluxDBClient) CreateAdmin(user, password string) error
  • func (c InfluxDBClient) CreateDB(db string) error
  • func (c InfluxDBClient) DropAdmin(user string) error
  • func (c InfluxDBClient) DropDB(db string) error
  • func (c InfluxDBClient) Flush() (int, error)
  • func (c InfluxDBClient) GetDBList() ([]string, error)
  • func (c InfluxDBClient) GetTableList(db string) ([]string, error)
  • func (c InfluxDBClient) GetUserList() ([]string, error)
  • func (c InfluxDBClient) Ping() error
  • func (c InfluxDBClient) SendLines(host, database string, raw_data []byte) ([]byte, error)
  • func (c InfluxDBClient) TableSize(db, table string) (int, error)

Types

type BatchPoints

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

func NewBatchPoints

func NewBatchPoints(db, precision string) *BatchPoints

func (*BatchPoints) AddPoint

func (bp *BatchPoints) AddPoint(p *client.Point)

func (*BatchPoints) AddPoints

func (bp *BatchPoints) AddPoints(ps []*client.Point)

func (*BatchPoints) Clear

func (bp *BatchPoints) Clear()

func (*BatchPoints) Database

func (bp *BatchPoints) Database() string

func (*BatchPoints) Points

func (bp *BatchPoints) Points() []*client.Point

func (*BatchPoints) Precision

func (bp *BatchPoints) Precision() string

func (*BatchPoints) RetentionPolicy

func (bp *BatchPoints) RetentionPolicy() string

func (*BatchPoints) SetDatabase

func (bp *BatchPoints) SetDatabase(db string)

func (*BatchPoints) SetPrecision

func (bp *BatchPoints) SetPrecision(p string) error

func (*BatchPoints) SetRetentionPolicy

func (bp *BatchPoints) SetRetentionPolicy(rp string)

func (*BatchPoints) SetWriteConsistency

func (bp *BatchPoints) SetWriteConsistency(wc string)

func (*BatchPoints) Size

func (bp *BatchPoints) Size() int

func (*BatchPoints) WriteConsistency

func (bp *BatchPoints) WriteConsistency() string

type InfluxDBClient

type InfluxDBClient struct {
	client.Client
	// contains filtered or unexported fields
}

func NewInfluxDBClient

func NewInfluxDBClient(host, user, password, db, precision string) (InfluxDBClient, error)

func (InfluxDBClient) AddPoint

func (c InfluxDBClient) AddPoint(pt *client.Point)

func (InfluxDBClient) AddPointData

func (c InfluxDBClient) AddPointData(table string, tags map[string]string, fields map[string]interface{}, t time.Time) error

func (InfluxDBClient) BatchPointSize

func (c InfluxDBClient) BatchPointSize() int

return current point number

func (InfluxDBClient) Close

func (c InfluxDBClient) Close() error

func (InfluxDBClient) CreateAdmin

func (c InfluxDBClient) CreateAdmin(user, password string) error

func (InfluxDBClient) CreateDB

func (c InfluxDBClient) CreateDB(db string) error

func (InfluxDBClient) DropAdmin

func (c InfluxDBClient) DropAdmin(user string) error

func (InfluxDBClient) DropDB

func (c InfluxDBClient) DropDB(db string) error

func (InfluxDBClient) Flush

func (c InfluxDBClient) Flush() (int, error)

func (InfluxDBClient) GetDBList

func (c InfluxDBClient) GetDBList() ([]string, error)

func (InfluxDBClient) GetTableList

func (c InfluxDBClient) GetTableList(db string) ([]string, error)

func (InfluxDBClient) GetUserList

func (c InfluxDBClient) GetUserList() ([]string, error)

func (InfluxDBClient) Ping

func (c InfluxDBClient) Ping() error

func (InfluxDBClient) SendLines

func (c InfluxDBClient) SendLines(host, database string, raw_data []byte) ([]byte, error)

from https://github.com/opera/logpeck/blob/master/sender_influxdb.go

func (InfluxDBClient) TableSize

func (c InfluxDBClient) TableSize(db, table string) (int, error)