Merge pull request #9 from slavaromanov/master

migrate to influxdb1-client/v2
cbrake · Oct 25, 2019 · 95f79ac · 95f79ac
2 parents 86de6eb + 9f3139e
commit 95f79ac
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 3 deletions.
diff --git a/client.go b/client.go
@@ -6,7 +6,7 @@ import (
 	"strings"
 	"time"
 
-	influxClient "github.com/influxdata/influxdb/client/v2"
+	influxClient "github.com/influxdata/influxdb1-client/v2"
 )
 
 var reRemoveExtraSpace = regexp.MustCompile(`\s\s+`)
@@ -108,6 +108,11 @@ func (c *helperClient) Query(q influxClient.Query) (*influxClient.Response, erro
 	return c.client.Query(q)
 }
 
+// QueryAsChunk -
+func (c *helperClient) QueryAsChunk(q influxClient.Query) (*influxClient.ChunkedResponse, error) {
+	return c.client.QueryAsChunk(q)
+}
+
 // Close releases any resources a Client may be using.
 func (c *helperClient) Close() error {
 	return c.client.Close()

diff --git a/decode.go b/decode.go
@@ -4,7 +4,7 @@ import (
 	"reflect"
 	"time"
 
-	influxModels "github.com/influxdata/influxdb/models"
+	influxModels "github.com/influxdata/influxdb1-client/models"
 	"github.com/mitchellh/mapstructure"
 )
 

diff --git a/decode_test.go b/decode_test.go
@@ -8,7 +8,7 @@ import (
 	"testing"
 	"time"
 
-	influxModels "github.com/influxdata/influxdb/models"
+	influxModels "github.com/influxdata/influxdb1-client/models"
 )
 
 func TestDecode(t *testing.T) {