gxinfluxdb

package
v0.3.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 9, 2020 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BatchPoints added in v0.3.2 

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

func NewBatchPoints added in v0.3.2 

func NewBatchPoints(db, precision string) *BatchPoints

func (*BatchPoints) AddPoint added in v0.3.2 

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

func (*BatchPoints) AddPoints added in v0.3.2 

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

func (*BatchPoints) Clear added in v0.3.2 

func (bp *BatchPoints) Clear()

func (*BatchPoints) Database added in v0.3.2 

func (bp *BatchPoints) Database() string

func (*BatchPoints) Points added in v0.3.2 

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

func (*BatchPoints) Precision added in v0.3.2 

func (bp *BatchPoints) Precision() string

func (*BatchPoints) RetentionPolicy added in v0.3.2 

func (bp *BatchPoints) RetentionPolicy() string

func (*BatchPoints) SetDatabase added in v0.3.2 

func (bp *BatchPoints) SetDatabase(db string)

func (*BatchPoints) SetPrecision added in v0.3.2 

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

func (*BatchPoints) SetRetentionPolicy added in v0.3.2 

func (bp *BatchPoints) SetRetentionPolicy(rp string)

func (*BatchPoints) SetWriteConsistency added in v0.3.2 

func (bp *BatchPoints) SetWriteConsistency(wc string)

func (*BatchPoints) Size added in v0.3.2 

func (bp *BatchPoints) Size() int

func (*BatchPoints) WriteConsistency added in v0.3.2 

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 added in v0.3.2 

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

func (InfluxDBClient) AddPointData added in v0.3.2 

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

func (InfluxDBClient) BatchPointSize added in v0.3.2 

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 added in v0.3.2 

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

func (InfluxDBClient) GetDBList added in v0.3.2 

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

func (InfluxDBClient) GetTableList added in v0.3.2 

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

func (InfluxDBClient) GetUserList added in v0.3.2 

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

func (InfluxDBClient) Ping 

func (c InfluxDBClient) Ping() error

func (InfluxDBClient) SendLines added in v0.3.2 

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)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.
JackTT - Gopher 🇻🇳