add fmt

.github/workflows/lint_and_test_go-client.yml

@@ -63,6 +63,10 @@ jobs:
         with:
           version: v1.55.2
           working-directory: ./go-client
+      - name: Format
+        working-directory: ./go-client
+        run: |
+          gofmt -d .
 
   build_server:
     name: Build server
@@ -115,5 +119,6 @@ jobs:
       - name: Run Go client tests
         working-directory: ./go-client
         run: |
-          make build
-          make ci
+          GO111MODULE=on make build
+          ./bin/echo > /dev/null 2>&1 &
+          GO111MODULE=on make ci

go-client/admin/client_test.go

@@ -78,20 +78,20 @@ func TestAdmin_CreateTableMustAvailable(t *testing.T) {
 	const tableName = "admin_table_test"
 
 	c := NewClient(Config{
-		MetaServers: []string{"0.0.0.0:34601"},
+		MetaServers: []string{"0.0.0.0:34601", "0.0.0.0:34602", "0.0.0.0:34603"},
 	})
 
 	ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
 	defer cancel()
 
-	err := c.CreateTable(context.Background(), tableName, 1)
+	err := c.CreateTable(context.Background(), tableName, 8)
 	if !assert.NoError(t, err) {
 		assert.Fail(t, err.Error())
 	}
 
 	// ensures the created table must be available for read and write
 	rwClient := pegasus.NewClient(pegasus.Config{
-		MetaServers: []string{"0.0.0.0:34601"},
+		MetaServers: []string{"0.0.0.0:34601", "0.0.0.0:34602", "0.0.0.0:34603"},
 	})
 	defer func() {
 		err = rwClient.Close()

go-client/example/main.go

@@ -65,7 +65,7 @@ func main() {
 	for t := 0; t < 10; t++ {
 		var sortKeys [][]byte
 		for i := 0; i < 10; i++ {
-			sortKeys = append(sortKeys, []byte("sort"+string(i)))
+			sortKeys = append(sortKeys, []byte("sort"+fmt.Sprint(i)))
 		}
 		for i := 0; i < 10; i++ {
 			err = tb.Set(context.Background(), []byte("hash"), sortKeys[i], value)