UKKO / influx_client_go

Go to a project
Toggle navigation Toggle navigation pinning
Iker Narvaez
c578e887 1 parent 6de85969

fix constructor

Inline Side-by-side
Showing 1 changed file with 4 additions and 2 deletions
...@@ -12,7 +12,8 @@ type InfluxClient struct { ...@@ -12,7 +12,8 @@ type InfluxClient struct {
12 Db string 12 Db string
13 } 13 }
14 14
15 -func (i *InfluxClient) CreateClient(db string, username string, password string, dbAddress string){ 15 +func CreateClient(db string, username string, password string, dbAddress string) *InfluxClient {
16 + i := InfluxClient {}
16 i.Db = db 17 i.Db = db
17 i.Client, i.InfluxErr = influx.NewHTTPClient(influx.HTTPConfig{ 18 i.Client, i.InfluxErr = influx.NewHTTPClient(influx.HTTPConfig{
18 Addr: dbAddress, 19 Addr: dbAddress,
...@@ -22,9 +23,10 @@ func (i *InfluxClient) CreateClient(db string, username string, password string, ...@@ -22,9 +23,10 @@ func (i *InfluxClient) CreateClient(db string, username string, password string,
22 if i.InfluxErr != nil { 23 if i.InfluxErr != nil {
23 panic(i.InfluxErr) 24 panic(i.InfluxErr)
24 } 25 }
26 + return &i
25 } 27 }
26 28
27 -func (i *InfluxClient) createPoint(tableName string, tags map[string]string, fields map[string]interface{}, timestamp time.Time) { 29 +func (i *InfluxClient) CreatePoint(tableName string, tags map[string]string, fields map[string]interface{}, timestamp time.Time) {
28 bp, _ := influx.NewBatchPoints(influx.BatchPointsConfig{ 30 bp, _ := influx.NewBatchPoints(influx.BatchPointsConfig{
29 Database: i.Db, 31 Database: i.Db,
30 Precision: "s", 32 Precision: "s",
......