Merge pull request #15 from HarrisChu/replace_module

replace nebula-go with ccore

go.mod

@@ -3,7 +3,7 @@ module github.com/vesoft-inc/k6-plugin
 go 1.16
 
 require (
-	github.com/vesoft-inc/nebula-go/v3 v3.0.0-20220119024722-ab348afbb79d
+	github.com/vesoft-inc/nebula-http-gateway/ccore v0.0.0-20220215025312-993ec26095cb
 	go.k6.io/k6 v0.33.0
 	gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b // indirect
 )

go.sum

@@ -276,6 +276,7 @@ github.com/rogpeppe/fastuuid v0.0.0-20150106093220-6724a57986af/go.mod h1:XWv6So
 github.com/rogpeppe/go-internal v1.3.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4=
 github.com/russross/blackfriday/v2 v2.0.1/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=
 github.com/ryanuber/columnize v0.0.0-20160712163229-9b3edd62028f/go.mod h1:sm1tb6uqfes/u+d4ooFouqFdy9/2g9QGwK3SQygK0Ts=
+github.com/satori/go.uuid v1.2.1-0.20181028125025-b2ce2384e17b/go.mod h1:dA0hQrYB0VpLJoorglMZABFdXlWrHn1NEOzdhQKdks0=
 github.com/sean-/seed v0.0.0-20170313163322-e2103e2c3529/go.mod h1:DxrIzT+xaE7yg65j358z/aeFdxmN0P9QXhEzd20vsDc=
 github.com/serenize/snaker v0.0.0-20171204205717-a683aaf2d516/go.mod h1:Yow6lPLSAXx2ifx470yD/nUe22Dv5vBvxK/UK9UUTVs=
 github.com/serenize/snaker v0.0.0-20201027110005-a7ad2135616e h1:zWKUYT07mGmVBH+9UgnHXd/ekCK99C8EbDSAt5qsjXE=
@@ -324,8 +325,8 @@ github.com/ugorji/go/codec v1.1.7/go.mod h1:Ax+UKWsSmolVDwsd+7N3ZtXu+yMGCf907BLY
 github.com/urfave/negroni v0.3.1-0.20180130044549-22c5532ea862/go.mod h1:Meg73S6kFm/4PpbYdq35yYWoCZ9mS/YSx+lKnmiohz4=
 github.com/valyala/bytebufferpool v1.0.0/go.mod h1:6bBcMArwyJ5K/AmCkWv1jt77kVWyCJ6HpOuEn7z0Csc=
 github.com/valyala/fasttemplate v0.0.0-20170224212429-dcecefd839c4/go.mod h1:50wTf68f99/Zt14pr046Tgt3Lp2vLyFZKzbFXTOabXw=
-github.com/vesoft-inc/nebula-go/v3 v3.0.0-20220119024722-ab348afbb79d h1:spO7OAtYI1wiqBiJ9417pKhqx0IkqFAFdFQFPm4JIrs=
-github.com/vesoft-inc/nebula-go/v3 v3.0.0-20220119024722-ab348afbb79d/go.mod h1:+sXv05jYQBARdTbTcIEsWVXCnF/6ttOlDK35xQ6m54s=
+github.com/vesoft-inc/nebula-http-gateway/ccore v0.0.0-20220215025312-993ec26095cb h1:cX6Ghc0soBHbpPUlFgUnX4saVa3cBJTL2+SwiRrZKu4=
+github.com/vesoft-inc/nebula-http-gateway/ccore v0.0.0-20220215025312-993ec26095cb/go.mod h1:sFEvE+cY4TgwqWx6H6msOqAUzRhsEHHKaaMgIZENHuQ=
 github.com/xiang90/probing v0.0.0-20190116061207-43a291ad63a2/go.mod h1:UETIi67q53MR2AWcXfiuqkDkRtnGDLqkBTpCHuJHxtU=
 github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
 github.com/yuin/goldmark v1.1.32/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=

csv.go → pkg/common/csv.go

@@ -1,24 +1,26 @@
-package nebulagraph
+package common
 
 import (
 	"encoding/csv"
 	"io"
 	"os"
 )
 
-type CSVReader struct {
-	Path       string
-	Delimiter  string
-	WithHeader bool
-	DataCh     chan<- Data
-}
+type (
+	CSVReader struct {
+		Path       string
+		Delimiter  string
+		WithHeader bool
+		DataCh     chan<- Data
+	}
 
-type CSVWriter struct {
-	Path      string
-	Header    []string
-	Delimiter string
-	DataCh    <-chan []string
-}
+	CSVWriter struct {
+		Path      string
+		Header    []string
+		Delimiter string
+		DataCh    <-chan []string
+	}
+)
 
 func NewCsvReader(path, delimiter string, withHeader bool, dataCh chan<- Data) *CSVReader {
 	return &CSVReader{