helper

Documentation

Index

• func Influx1xClientConf(addr, user, pwd string) *client.Config
• func Influx1xClientPing(conf *client.Config) error
• func Influx1xClientWrite(con *client.Client, datasource, policy, name string, tags *map[string]string, ...) error
• func Interface2Float64(inter interface{}) (float64, error)
• func MergeSlice(s1 []interface{}, s2 []interface{}) []interface{}
• func New(size int) *pool
• func NewInfluxdbClient(conf *client.Config) (*client.Client, error)
• func SocketChenNew(i int) *socketByteChan

Functions

func Influx1xClientConf

func Influx1xClientConf(addr, user, pwd string) *client.Config

func Influx1xClientPing

func Influx1xClientPing(conf *client.Config) error

func Influx1xClientWrite

func Influx1xClientWrite(con *client.Client, datasource, policy, name string, tags *map[string]string, fields *map[time.Time]float64) error

func Interface2Float64

func Interface2Float64(inter interface{}) (float64, error)

func MergeSlice

func MergeSlice(s1 []interface{}, s2 []interface{}) []interface{}

func New

func New(size int) *pool

func NewInfluxdbClient

func NewInfluxdbClient(conf *client.Config) (*client.Client, error)

func SocketChenNew

func SocketChenNew(i int) *socketByteChan