gxinfluxdb

package

v1.0.0 Latest Latest Go to latest Published: Sep 7, 2026 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/danielmercer0503/goext

Links

Open Source Insights

Documentation ¶

Overview ¶

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

Index ¶

type BatchPoints
- func NewBatchPoints(db, precision string) *BatchPoints
type InfluxDBClient
- func NewInfluxDBClient(host, user, password, db, precision string) (InfluxDBClient, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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)

Source Files ¶

View all Source files

influxdb.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL