client mod

GreptimeTeam · Jan 12, 2024 · 073ce6d · 073ce6d
1 parent 3b16fe9
commit 073ce6d
Show file tree

Hide file tree

Showing 8 changed files with 8 additions and 9 deletions.
diff --git a/.github/workflows/lint.yml b/.github/workflows/lint.yml
@@ -6,9 +6,8 @@ permissions:
   # Optional: allow read access to pull request. Use with `only-new-issues` option.
   # pull-requests: read
 jobs:
-  golangci:
+  lint:
     if: github.event.pull_request.draft == false
-    name: lint
     runs-on: ubuntu-latest
     steps:
       - uses: actions/setup-go@v3

diff --git a/client.go → client/client.go b/client.go → client/client.go
@@ -20,8 +20,8 @@ import (
 	greptimepb "github.com/GreptimeTeam/greptime-proto/go/greptime/v1"
 	"google.golang.org/grpc"
 
+	"github.com/GreptimeTeam/greptimedb-ingester-go/client/insert"
 	"github.com/GreptimeTeam/greptimedb-ingester-go/config"
-	"github.com/GreptimeTeam/greptimedb-ingester-go/insert"
 )
 
 // Client helps to Insert/Query data Into/From GreptimeDB. A Client is safe for concurrent
@@ -33,8 +33,8 @@ type Client struct {
 	greptimeClient greptimepb.GreptimeDatabaseClient
 }
 
-// NewClient helps to create the greptimedb client, which will be responsible Write/Read data To/From GreptimeDB
-func NewClient(cfg *config.Config) (*Client, error) {
+// New helps to create the greptimedb client, which will be responsible Write/Read data To/From GreptimeDB
+func New(cfg *config.Config) (*Client, error) {
 	conn, err := grpc.Dial(cfg.GetGRPCAddr(), cfg.DialOptions...)
 	if err != nil {
 		return nil, err

diff --git a/client_test.go → client/client_test.go b/client_test.go → client/client_test.go
diff --git a/insert/header.go → client/insert/header.go b/insert/header.go → client/insert/header.go
diff --git a/insert/header_test.go → client/insert/header_test.go b/insert/header_test.go → client/insert/header_test.go
diff --git a/insert/insert.go → client/insert/insert.go b/insert/insert.go → client/insert/insert.go
diff --git a/stream_client.go → client/stream/client.go b/stream_client.go → client/stream/client.go
@@ -12,16 +12,16 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-package greptime
+package stream
 
 import (
 	"context"
 
 	greptimepb "github.com/GreptimeTeam/greptime-proto/go/greptime/v1"
 	"google.golang.org/grpc"
 
+	"github.com/GreptimeTeam/greptimedb-ingester-go/client/insert"
 	"github.com/GreptimeTeam/greptimedb-ingester-go/config"
-	"github.com/GreptimeTeam/greptimedb-ingester-go/insert"
 )
 
 // StreamClient is only for inserting
@@ -32,7 +32,7 @@ type StreamClient struct {
 
 // NewStreamClient helps to create a stream insert client.
 // If Client has performance issue, you can try the stream client.
-func NewStreamClient(cfg *config.Config) (*StreamClient, error) {
+func New(cfg *config.Config) (*StreamClient, error) {
 	conn, err := grpc.Dial(cfg.GetGRPCAddr(), cfg.DialOptions...)
 	if err != nil {
 		return nil, err

diff --git a/stream_client_test.go → client/stream/client_test.go b/stream_client_test.go → client/stream/client_test.go
@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-package greptime
+package stream
 
 import (
 	"testing"