influxgo

package module

v0.0.6 Latest Latest Go to latest Published: Apr 15, 2021 License: Apache-2.0 Imports: 9 Imported by: 0

Details

A simple library to write and query influxdb,

This Library only support some simple features :

It need influxdb1.8.x or before

This section is empty.

This section is empty.

This section is empty.

type IfxCli struct {
	Ip       string
	Port     int
	User     string
	PassWord string
	// contains filtered or unexported fields
}

func NewClient(ip string, port int, user, passWord string) *IfxCli

create a new influxdb client; if the user and password was not be set in your influxdb server, set it as ""

func (f *IfxCli) GetDatabases() ([]string, error)

get all the name of databases

func (f *IfxCli) Ping() error

func (f *IfxCli) QueryBetweenWithTag(
	db, measure, tagName, tagValue string, start, end int, timeType string) (QueryResp, error)

func (f *IfxCli) QueryLastNTime(db, measure string, n int, tp string) (QueryResp, error)

query the latest time data; n: the number of time duration; timeType support: "s": second, "m": minute, "h": hour, "d": day, "w": week

func (f *IfxCli) QueryLastNTimeByTag(db, measure, tagName, tagValue string, n int, timeType string) (QueryResp, error)

query the latest time data by set the tag, n: the number of time duration timeType support: "s": second, "m": minute, "h": hour, "d": day, "w": week

func (f *IfxCli) QueryMeasure(start, end time.Time)

func (f *IfxCli) Write(data WriteData) error

type IfxResp struct {
	Name    string     `json:"name"`
	Columns []string   `json:"columns"`
	Values  [][]string `json:"values"`
}

github.com/cngobd/influxgo

type QueryResp struct {
	Columns []string
	Values  [][]interface{}
}

type WriteData struct {
	DB          string
	Measurement string
	Tags        map[string]interface{}
	Fields      map[string]interface{}
}