This is an automated email from the ASF dual-hosted git repository.
zhaoliwei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
The following commit(s) were added to refs/heads/master by this push:
new 0c834d9c chore(go-client): Use apache instead of xiaomi in urls (#981)
0c834d9c is described below
commit 0c834d9c23f04c480868da76924d2d3d8fbf20b4
Author: Yingchun Lai <[email protected]>
AuthorDate: Thu May 26 12:02:41 2022 +0800
chore(go-client): Use apache instead of xiaomi in urls (#981)
---
.github/workflows/lint_and_test_go-client.yml | 2 +-
README.md | 2 +-
go-client/README.md | 10 +++-------
go-client/admin/client.go | 6 +++---
go-client/admin/client_test.go | 2 +-
go-client/admin/remote_cmd_client.go | 6 +++---
go-client/admin/remote_cmd_client_test.go | 2 +-
go-client/docs/how_to_add_new_interface.md | 2 +-
go-client/example/full_scan.md | 4 ++--
go-client/example/main.go | 4 ++--
go-client/generator/main.go | 8 ++++----
go-client/go.mod | 2 +-
go-client/idl/admin/admin-consts.go | 2 +-
go-client/idl/admin/admin.go | 2 +-
go-client/idl/base/gpid_test.go | 2 +-
go-client/idl/radmin/radmin-consts.go | 2 +-
go-client/idl/radmin/radmin.go | 2 +-
go-client/idl/replication/replication-consts.go | 2 +-
go-client/idl/replication/replication.go | 2 +-
go-client/idl/rrdb/rrdb-consts.go | 4 ++--
go-client/idl/rrdb/rrdb.go | 4 ++--
go-client/integration/failover-test/main.go | 4 ++--
go-client/pegasus/check_and_set.go | 2 +-
go-client/pegasus/client.go | 4 ++--
go-client/pegasus/filter.go | 2 +-
go-client/pegasus/main_test.go | 2 +-
go-client/pegasus/op/check_and_set.go | 6 +++---
go-client/pegasus/op/del.go | 4 ++--
go-client/pegasus/op/get.go | 4 ++--
go-client/pegasus/op/incr.go | 6 +++---
go-client/pegasus/op/multidel.go | 6 +++---
go-client/pegasus/op/multiget.go | 6 +++---
go-client/pegasus/op/multiset.go | 6 +++---
go-client/pegasus/op/op.go | 4 ++--
go-client/pegasus/op/set.go | 6 +++---
go-client/pegasus/op/sortkey_count.go | 4 ++--
go-client/pegasus/op/ttl.go | 4 ++--
go-client/pegasus/op/utils.go | 2 +-
go-client/pegasus/retry_failover_test.go | 2 +-
go-client/pegasus/scan_test.go | 6 +++---
go-client/pegasus/scanner.go | 6 +++---
go-client/pegasus/table_connector.go | 12 ++++++------
go-client/pegasus/table_connector_test.go | 8 ++++----
go-client/pegasus/util.go | 2 +-
go-client/rpc/main_test.go | 2 +-
go-client/rpc/rpc_conn.go | 2 +-
go-client/session/admin_rpc_types.go | 4 ++--
go-client/session/codec.go | 16 ++++++++--------
go-client/session/codec_test.go | 6 +++---
go-client/session/header.go | 2 +-
go-client/session/main_test.go | 2 +-
go-client/session/meta_call.go | 2 +-
go-client/session/meta_session.go | 8 ++++----
go-client/session/meta_session_test.go | 2 +-
go-client/session/radmin_rpc_types.go | 4 ++--
go-client/session/replica_session.go | 4 ++--
go-client/session/session.go | 6 +++---
go-client/session/session_test.go | 10 +++++-----
go-client/session/session_timeout_test.go | 2 +-
59 files changed, 124 insertions(+), 128 deletions(-)
diff --git a/.github/workflows/lint_and_test_go-client.yml
b/.github/workflows/lint_and_test_go-client.yml
index 4debfeb2..df57cf56 100644
--- a/.github/workflows/lint_and_test_go-client.yml
+++ b/.github/workflows/lint_and_test_go-client.yml
@@ -64,6 +64,6 @@ jobs:
- name: Run Test
run: ./test.sh
working-directory: ./go-client
- - uses: codecov/codecov-action@v1
+ - uses: codecov/codecov-action@v2
with:
working-directory: ./go-client
diff --git a/README.md b/README.md
index 4b7ba928..31e830e1 100644
--- a/README.md
+++ b/README.md
@@ -75,7 +75,7 @@ Pegasus has support for several languages:
- [Java](https://github.com/apache/incubator-pegasus/blob/master/java-client)
<!-- markdown-link-check-enable-->
-
[C++](https://github.com/apache/incubator-pegasus/blob/master/src/include/pegasus/client.h)
-- [Go](https://github.com/xiaomi/pegasus-go-client)
+- [Go](https://github.com/apache/incubator-pegasus/go-client)
- [Python](https://github.com/xiaomi/pegasus-python-client)
- [Node.js](https://github.com/xiaomi/pegasus-nodejs-client)
- [Scala](https://github.com/apache/incubator-pegasus/blob/master/scala-client)
diff --git a/go-client/README.md b/go-client/README.md
index 6b4be30c..82e02195 100644
--- a/go-client/README.md
+++ b/go-client/README.md
@@ -18,15 +18,11 @@ under the License.
-->
# pegasus-go-client
-[](https://codecov.io/gh/xiaomi/pegasus-go-client)
-
-[](https://goreportcard.com/report/github.com/XiaoMi/pegasus-go-client)
-
-[](https://pkg.go.dev/github.com/xiaomi/pegasus-go-client)
+[](https://goreportcard.com/report/github.com/apache/incubator-pegasus/go-client)
## Requirement
-Go1.12+.
+Go1.14+.
## Logging
@@ -60,7 +56,7 @@ support for other log destinations or log formats, please
submit an issue for th
import (
"context"
- "github.com/XiaoMi/pegasus-go-client/pegasus"
+ "github.com/apache/incubator-pegasus/go-client/pegasus"
)
cfg := Config{
diff --git a/go-client/admin/client.go b/go-client/admin/client.go
index c18da1c5..efdc8ff5 100644
--- a/go-client/admin/client.go
+++ b/go-client/admin/client.go
@@ -24,9 +24,9 @@ import (
"fmt"
"time"
- "github.com/XiaoMi/pegasus-go-client/idl/admin"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/session"
+ "github.com/apache/incubator-pegasus/go-client/idl/admin"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/session"
)
// Client provides the administration API to a specific cluster.
diff --git a/go-client/admin/client_test.go b/go-client/admin/client_test.go
index 1185bef1..bd2b7b63 100644
--- a/go-client/admin/client_test.go
+++ b/go-client/admin/client_test.go
@@ -25,7 +25,7 @@ import (
"testing"
"time"
- "github.com/XiaoMi/pegasus-go-client/pegasus"
+ "github.com/apache/incubator-pegasus/go-client/pegasus"
"github.com/stretchr/testify/assert"
)
diff --git a/go-client/admin/remote_cmd_client.go
b/go-client/admin/remote_cmd_client.go
index 190d720b..8acf6446 100644
--- a/go-client/admin/remote_cmd_client.go
+++ b/go-client/admin/remote_cmd_client.go
@@ -20,9 +20,9 @@ package admin
import (
"context"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/idl/cmd"
- "github.com/XiaoMi/pegasus-go-client/session"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/cmd"
+ "github.com/apache/incubator-pegasus/go-client/session"
)
// RemoteCmdClient is a client to call remote command to a PegasusServer.
diff --git a/go-client/admin/remote_cmd_client_test.go
b/go-client/admin/remote_cmd_client_test.go
index f903833b..7fad7e54 100644
--- a/go-client/admin/remote_cmd_client_test.go
+++ b/go-client/admin/remote_cmd_client_test.go
@@ -25,7 +25,7 @@ import (
"github.com/stretchr/testify/assert"
- "github.com/XiaoMi/pegasus-go-client/session"
+ "github.com/apache/incubator-pegasus/go-client/session"
)
func TestAdmin_RemoteCommandCall(t *testing.T) {
diff --git a/go-client/docs/how_to_add_new_interface.md
b/go-client/docs/how_to_add_new_interface.md
index 0fa7b84f..5bc9832a 100644
--- a/go-client/docs/how_to_add_new_interface.md
+++ b/go-client/docs/how_to_add_new_interface.md
@@ -40,7 +40,7 @@ you can follow [the building manual of
thrift](https://thrift.apache.org/docs/Bu
3. Compile thrift files to generate go code.
```sh
-thrift -I idl -out idl --gen
go:thrift_import='github.com/apache/thrift/lib/go/thrift',package_prefix='github.com/XiaoMi/pegasus-go-client/idl/'
idl/admin.thrift
+thrift -I idl -out idl --gen
go:thrift_import='github.com/apache/thrift/lib/go/thrift',package_prefix='github.com/apache/incubator-pegasus/go-client/idl/'
idl/admin.thrift
gofmt -w **/*.go
goimports -w */**.go
```
diff --git a/go-client/example/full_scan.md b/go-client/example/full_scan.md
index f34f48a9..524d5361 100644
--- a/go-client/example/full_scan.md
+++ b/go-client/example/full_scan.md
@@ -38,8 +38,8 @@ import (
"encoding/binary"
"time"
- "github.com/XiaoMi/pegasus-go-client/pegalog"
- "github.com/XiaoMi/pegasus-go-client/pegasus"
+ "github.com/apache/incubator-pegasus/go-client/pegalog"
+ "github.com/apache/incubator-pegasus/go-client/pegasus"
)
func searchHistoryOneYearAgo() {
diff --git a/go-client/example/main.go b/go-client/example/main.go
index f1532481..2d679f28 100644
--- a/go-client/example/main.go
+++ b/go-client/example/main.go
@@ -27,8 +27,8 @@ import (
"path/filepath"
"time"
- "github.com/XiaoMi/pegasus-go-client/pegalog"
- "github.com/XiaoMi/pegasus-go-client/pegasus"
+ "github.com/apache/incubator-pegasus/go-client/pegalog"
+ "github.com/apache/incubator-pegasus/go-client/pegasus"
)
func main() {
diff --git a/go-client/generator/main.go b/go-client/generator/main.go
index af242808..4be929ee 100644
--- a/go-client/generator/main.go
+++ b/go-client/generator/main.go
@@ -103,8 +103,8 @@ import (
"context"
"fmt"
- "github.com/XiaoMi/pegasus-go-client/idl/admin"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/admin"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
)
`)
@@ -179,8 +179,8 @@ import (
"context"
"fmt"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/idl/radmin"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/radmin"
)
`)
diff --git a/go-client/go.mod b/go-client/go.mod
index 38d50d74..8367ef0b 100644
--- a/go-client/go.mod
+++ b/go-client/go.mod
@@ -15,7 +15,7 @@
// specific language governing permissions and limitations
// under the License.
-module github.com/XiaoMi/pegasus-go-client
+module github.com/apache/incubator-pegasus/go-client
go 1.13
diff --git a/go-client/idl/admin/admin-consts.go
b/go-client/idl/admin/admin-consts.go
index 37e5b4c5..7efc5b0c 100644
--- a/go-client/idl/admin/admin-consts.go
+++ b/go-client/idl/admin/admin-consts.go
@@ -7,7 +7,7 @@ import (
"bytes"
"context"
"fmt"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
"github.com/apache/thrift/lib/go/thrift"
"reflect"
)
diff --git a/go-client/idl/admin/admin.go b/go-client/idl/admin/admin.go
index 4fa01133..cd0cf134 100644
--- a/go-client/idl/admin/admin.go
+++ b/go-client/idl/admin/admin.go
@@ -9,7 +9,7 @@ import (
"database/sql/driver"
"errors"
"fmt"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
"github.com/apache/thrift/lib/go/thrift"
"reflect"
)
diff --git a/go-client/idl/base/gpid_test.go b/go-client/idl/base/gpid_test.go
index d8e05116..06435431 100644
--- a/go-client/idl/base/gpid_test.go
+++ b/go-client/idl/base/gpid_test.go
@@ -3,7 +3,7 @@ package base
import (
"testing"
- "github.com/XiaoMi/pegasus-go-client/pegalog"
+ "github.com/apache/incubator-pegasus/go-client/pegalog"
"github.com/apache/thrift/lib/go/thrift"
"github.com/stretchr/testify/assert"
)
diff --git a/go-client/idl/radmin/radmin-consts.go
b/go-client/idl/radmin/radmin-consts.go
index 6dfec694..e96ccaaa 100644
--- a/go-client/idl/radmin/radmin-consts.go
+++ b/go-client/idl/radmin/radmin-consts.go
@@ -7,7 +7,7 @@ import (
"bytes"
"context"
"fmt"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
"github.com/apache/thrift/lib/go/thrift"
"reflect"
)
diff --git a/go-client/idl/radmin/radmin.go b/go-client/idl/radmin/radmin.go
index 98cf27ed..78e7ad92 100644
--- a/go-client/idl/radmin/radmin.go
+++ b/go-client/idl/radmin/radmin.go
@@ -7,7 +7,7 @@ import (
"bytes"
"context"
"fmt"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
"github.com/apache/thrift/lib/go/thrift"
"reflect"
)
diff --git a/go-client/idl/replication/replication-consts.go
b/go-client/idl/replication/replication-consts.go
index c8a6aa4d..da6f5761 100644
--- a/go-client/idl/replication/replication-consts.go
+++ b/go-client/idl/replication/replication-consts.go
@@ -7,7 +7,7 @@ import (
"bytes"
"context"
"fmt"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
"github.com/apache/thrift/lib/go/thrift"
"reflect"
)
diff --git a/go-client/idl/replication/replication.go
b/go-client/idl/replication/replication.go
index 7e6fe903..0e402c18 100644
--- a/go-client/idl/replication/replication.go
+++ b/go-client/idl/replication/replication.go
@@ -7,7 +7,7 @@ import (
"bytes"
"context"
"fmt"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
"github.com/apache/thrift/lib/go/thrift"
"reflect"
)
diff --git a/go-client/idl/rrdb/rrdb-consts.go
b/go-client/idl/rrdb/rrdb-consts.go
index 6092b073..5af489cb 100644
--- a/go-client/idl/rrdb/rrdb-consts.go
+++ b/go-client/idl/rrdb/rrdb-consts.go
@@ -7,8 +7,8 @@ import (
"bytes"
"context"
"fmt"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/idl/replication"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/replication"
"github.com/apache/thrift/lib/go/thrift"
"reflect"
)
diff --git a/go-client/idl/rrdb/rrdb.go b/go-client/idl/rrdb/rrdb.go
index 42464514..ab17225d 100644
--- a/go-client/idl/rrdb/rrdb.go
+++ b/go-client/idl/rrdb/rrdb.go
@@ -9,8 +9,8 @@ import (
"database/sql/driver"
"errors"
"fmt"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/idl/replication"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/replication"
"github.com/apache/thrift/lib/go/thrift"
"reflect"
)
diff --git a/go-client/integration/failover-test/main.go
b/go-client/integration/failover-test/main.go
index ad7f9a19..48105928 100644
--- a/go-client/integration/failover-test/main.go
+++ b/go-client/integration/failover-test/main.go
@@ -25,8 +25,8 @@ import (
"strings"
"time"
- "github.com/XiaoMi/pegasus-go-client/pegalog"
- "github.com/XiaoMi/pegasus-go-client/pegasus"
+ "github.com/apache/incubator-pegasus/go-client/pegalog"
+ "github.com/apache/incubator-pegasus/go-client/pegasus"
)
// This test intends to verify if go-client can failover automatically on TCP
breakdown.
diff --git a/go-client/pegasus/check_and_set.go
b/go-client/pegasus/check_and_set.go
index d2127597..8fb29aac 100644
--- a/go-client/pegasus/check_and_set.go
+++ b/go-client/pegasus/check_and_set.go
@@ -19,7 +19,7 @@
package pegasus
-import "github.com/XiaoMi/pegasus-go-client/idl/rrdb"
+import "github.com/apache/incubator-pegasus/go-client/idl/rrdb"
// CheckType defines the types of value checking in a CAS.
type CheckType int
diff --git a/go-client/pegasus/client.go b/go-client/pegasus/client.go
index 9192d86e..aa20f107 100644
--- a/go-client/pegasus/client.go
+++ b/go-client/pegasus/client.go
@@ -23,8 +23,8 @@ import (
"context"
"sync"
- "github.com/XiaoMi/pegasus-go-client/pegalog"
- "github.com/XiaoMi/pegasus-go-client/session"
+ "github.com/apache/incubator-pegasus/go-client/pegalog"
+ "github.com/apache/incubator-pegasus/go-client/session"
)
// Client manages the client sessions to the pegasus cluster specified by
`Config`.
diff --git a/go-client/pegasus/filter.go b/go-client/pegasus/filter.go
index 4ccae021..24c4fe61 100644
--- a/go-client/pegasus/filter.go
+++ b/go-client/pegasus/filter.go
@@ -19,7 +19,7 @@
package pegasus
-import "github.com/XiaoMi/pegasus-go-client/idl/rrdb"
+import "github.com/apache/incubator-pegasus/go-client/idl/rrdb"
// FilterType defines the type of key filtering.
type FilterType int
diff --git a/go-client/pegasus/main_test.go b/go-client/pegasus/main_test.go
index fc2af633..32bc938d 100644
--- a/go-client/pegasus/main_test.go
+++ b/go-client/pegasus/main_test.go
@@ -23,7 +23,7 @@ import (
"os"
"testing"
- "github.com/XiaoMi/pegasus-go-client/pegalog"
+ "github.com/apache/incubator-pegasus/go-client/pegalog"
)
func TestMain(m *testing.M) {
diff --git a/go-client/pegasus/op/check_and_set.go
b/go-client/pegasus/op/check_and_set.go
index 1e604be6..3f213d17 100644
--- a/go-client/pegasus/op/check_and_set.go
+++ b/go-client/pegasus/op/check_and_set.go
@@ -23,9 +23,9 @@ import (
"context"
"time"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/idl/rrdb"
- "github.com/XiaoMi/pegasus-go-client/session"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/rrdb"
+ "github.com/apache/incubator-pegasus/go-client/session"
)
// CheckAndSet inherits op.Request.
diff --git a/go-client/pegasus/op/del.go b/go-client/pegasus/op/del.go
index 63c306c0..549d590d 100644
--- a/go-client/pegasus/op/del.go
+++ b/go-client/pegasus/op/del.go
@@ -22,8 +22,8 @@ package op
import (
"context"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/session"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/session"
)
// Del inherits op.Request.
diff --git a/go-client/pegasus/op/get.go b/go-client/pegasus/op/get.go
index 11a8b606..fde76c2a 100644
--- a/go-client/pegasus/op/get.go
+++ b/go-client/pegasus/op/get.go
@@ -22,8 +22,8 @@ package op
import (
"context"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/session"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/session"
)
// Get inherits op.Request.
diff --git a/go-client/pegasus/op/incr.go b/go-client/pegasus/op/incr.go
index 4ad2e682..336a7f90 100644
--- a/go-client/pegasus/op/incr.go
+++ b/go-client/pegasus/op/incr.go
@@ -22,9 +22,9 @@ package op
import (
"context"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/idl/rrdb"
- "github.com/XiaoMi/pegasus-go-client/session"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/rrdb"
+ "github.com/apache/incubator-pegasus/go-client/session"
)
// Incr inherits op.Request.
diff --git a/go-client/pegasus/op/multidel.go b/go-client/pegasus/op/multidel.go
index 1c1e376a..20c01c43 100644
--- a/go-client/pegasus/op/multidel.go
+++ b/go-client/pegasus/op/multidel.go
@@ -22,9 +22,9 @@ package op
import (
"context"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/idl/rrdb"
- "github.com/XiaoMi/pegasus-go-client/session"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/rrdb"
+ "github.com/apache/incubator-pegasus/go-client/session"
)
// MultiDel inherits op.Request.
diff --git a/go-client/pegasus/op/multiget.go b/go-client/pegasus/op/multiget.go
index bf1f0b9d..12931901 100644
--- a/go-client/pegasus/op/multiget.go
+++ b/go-client/pegasus/op/multiget.go
@@ -22,9 +22,9 @@ package op
import (
"context"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/idl/rrdb"
- "github.com/XiaoMi/pegasus-go-client/session"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/rrdb"
+ "github.com/apache/incubator-pegasus/go-client/session"
)
// MultiGet inherits op.Request.
diff --git a/go-client/pegasus/op/multiset.go b/go-client/pegasus/op/multiset.go
index 09f907ea..5c70d097 100644
--- a/go-client/pegasus/op/multiset.go
+++ b/go-client/pegasus/op/multiset.go
@@ -24,9 +24,9 @@ import (
"fmt"
"time"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/idl/rrdb"
- "github.com/XiaoMi/pegasus-go-client/session"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/rrdb"
+ "github.com/apache/incubator-pegasus/go-client/session"
)
// MultiSet inherits op.Request.
diff --git a/go-client/pegasus/op/op.go b/go-client/pegasus/op/op.go
index f318e33f..afdff8c1 100644
--- a/go-client/pegasus/op/op.go
+++ b/go-client/pegasus/op/op.go
@@ -22,8 +22,8 @@ package op
import (
"context"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/session"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/session"
)
// Request is the generic interface of all Pegasus operations.
diff --git a/go-client/pegasus/op/set.go b/go-client/pegasus/op/set.go
index 7adf4d8c..bd587af1 100644
--- a/go-client/pegasus/op/set.go
+++ b/go-client/pegasus/op/set.go
@@ -23,9 +23,9 @@ import (
"context"
"time"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/idl/rrdb"
- "github.com/XiaoMi/pegasus-go-client/session"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/rrdb"
+ "github.com/apache/incubator-pegasus/go-client/session"
)
// Set inherits op.Request.
diff --git a/go-client/pegasus/op/sortkey_count.go
b/go-client/pegasus/op/sortkey_count.go
index 14db67b2..2cf1c135 100644
--- a/go-client/pegasus/op/sortkey_count.go
+++ b/go-client/pegasus/op/sortkey_count.go
@@ -22,8 +22,8 @@ package op
import (
"context"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/session"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/session"
)
// SortKeyCount inherits op.Request.
diff --git a/go-client/pegasus/op/ttl.go b/go-client/pegasus/op/ttl.go
index 8c488085..e18cb578 100644
--- a/go-client/pegasus/op/ttl.go
+++ b/go-client/pegasus/op/ttl.go
@@ -22,8 +22,8 @@ package op
import (
"context"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/session"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/session"
)
// TTL inherits op.Request.
diff --git a/go-client/pegasus/op/utils.go b/go-client/pegasus/op/utils.go
index 8a5140a2..c6310d77 100644
--- a/go-client/pegasus/op/utils.go
+++ b/go-client/pegasus/op/utils.go
@@ -25,7 +25,7 @@ import (
"math"
"time"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
)
func validateHashKey(hashKey []byte) error {
diff --git a/go-client/pegasus/retry_failover_test.go
b/go-client/pegasus/retry_failover_test.go
index e0cb9b11..4820563c 100644
--- a/go-client/pegasus/retry_failover_test.go
+++ b/go-client/pegasus/retry_failover_test.go
@@ -24,7 +24,7 @@ import (
"testing"
"time"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
"github.com/stretchr/testify/assert"
)
diff --git a/go-client/pegasus/scan_test.go b/go-client/pegasus/scan_test.go
index d5aa9dfd..171abdc9 100644
--- a/go-client/pegasus/scan_test.go
+++ b/go-client/pegasus/scan_test.go
@@ -27,10 +27,10 @@ import (
"testing"
"time"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/idl/rrdb"
- "github.com/XiaoMi/pegasus-go-client/session"
"github.com/agiledragon/gomonkey"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/rrdb"
+ "github.com/apache/incubator-pegasus/go-client/session"
"github.com/fortytw2/leaktest"
"github.com/stretchr/testify/assert"
)
diff --git a/go-client/pegasus/scanner.go b/go-client/pegasus/scanner.go
index f4a53c56..d1238c06 100644
--- a/go-client/pegasus/scanner.go
+++ b/go-client/pegasus/scanner.go
@@ -26,9 +26,9 @@ import (
"sync/atomic"
"time"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/idl/rrdb"
- "github.com/XiaoMi/pegasus-go-client/pegalog"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/rrdb"
+ "github.com/apache/incubator-pegasus/go-client/pegalog"
)
// ScannerOptions is the options for GetScanner and GetUnorderedScanners.
diff --git a/go-client/pegasus/table_connector.go
b/go-client/pegasus/table_connector.go
index 18faac2d..0a000ae4 100644
--- a/go-client/pegasus/table_connector.go
+++ b/go-client/pegasus/table_connector.go
@@ -29,12 +29,12 @@ import (
"sync"
"time"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/idl/replication"
- "github.com/XiaoMi/pegasus-go-client/idl/rrdb"
- "github.com/XiaoMi/pegasus-go-client/pegalog"
- "github.com/XiaoMi/pegasus-go-client/pegasus/op"
- "github.com/XiaoMi/pegasus-go-client/session"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/replication"
+ "github.com/apache/incubator-pegasus/go-client/idl/rrdb"
+ "github.com/apache/incubator-pegasus/go-client/pegalog"
+ "github.com/apache/incubator-pegasus/go-client/pegasus/op"
+ "github.com/apache/incubator-pegasus/go-client/session"
"gopkg.in/tomb.v2"
kerrors "k8s.io/apimachinery/pkg/util/errors"
)
diff --git a/go-client/pegasus/table_connector_test.go
b/go-client/pegasus/table_connector_test.go
index f444354e..4aabe5eb 100644
--- a/go-client/pegasus/table_connector_test.go
+++ b/go-client/pegasus/table_connector_test.go
@@ -30,10 +30,10 @@ import (
"testing"
"time"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/idl/replication"
- "github.com/XiaoMi/pegasus-go-client/pegalog"
- "github.com/XiaoMi/pegasus-go-client/rpc"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/replication"
+ "github.com/apache/incubator-pegasus/go-client/pegalog"
+ "github.com/apache/incubator-pegasus/go-client/rpc"
"github.com/fortytw2/leaktest"
"github.com/stretchr/testify/assert"
)
diff --git a/go-client/pegasus/util.go b/go-client/pegasus/util.go
index 391f0e26..45b0422f 100644
--- a/go-client/pegasus/util.go
+++ b/go-client/pegasus/util.go
@@ -23,7 +23,7 @@ import (
"encoding/binary"
"hash/crc64"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
)
func encodeHashKeySortKey(hashKey []byte, sortKey []byte) *base.Blob {
diff --git a/go-client/rpc/main_test.go b/go-client/rpc/main_test.go
index 6b95d6be..102c20f6 100644
--- a/go-client/rpc/main_test.go
+++ b/go-client/rpc/main_test.go
@@ -23,7 +23,7 @@ import (
"os"
"testing"
- "github.com/XiaoMi/pegasus-go-client/pegalog"
+ "github.com/apache/incubator-pegasus/go-client/pegalog"
)
func TestMain(m *testing.M) {
diff --git a/go-client/rpc/rpc_conn.go b/go-client/rpc/rpc_conn.go
index f70ab70d..12fbc87c 100644
--- a/go-client/rpc/rpc_conn.go
+++ b/go-client/rpc/rpc_conn.go
@@ -26,7 +26,7 @@ import (
"sync"
"time"
- "github.com/XiaoMi/pegasus-go-client/pegalog"
+ "github.com/apache/incubator-pegasus/go-client/pegalog"
)
// TODO(wutao1): make these parameters configurable
diff --git a/go-client/session/admin_rpc_types.go
b/go-client/session/admin_rpc_types.go
index db0cc6d6..6ee36bc0 100644
--- a/go-client/session/admin_rpc_types.go
+++ b/go-client/session/admin_rpc_types.go
@@ -23,8 +23,8 @@ import (
"context"
"fmt"
- "github.com/XiaoMi/pegasus-go-client/idl/admin"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/admin"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
)
func (ms *metaSession) dropApp(ctx context.Context, req *admin.DropAppRequest)
(*admin.DropAppResponse, error) {
diff --git a/go-client/session/codec.go b/go-client/session/codec.go
index ca3e32d3..d5a3d306 100644
--- a/go-client/session/codec.go
+++ b/go-client/session/codec.go
@@ -26,14 +26,14 @@ import (
"sync"
"time"
- "github.com/XiaoMi/pegasus-go-client/idl/admin"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/idl/cmd"
- "github.com/XiaoMi/pegasus-go-client/idl/radmin"
- "github.com/XiaoMi/pegasus-go-client/idl/replication"
- "github.com/XiaoMi/pegasus-go-client/idl/rrdb"
- "github.com/XiaoMi/pegasus-go-client/pegalog"
- "github.com/XiaoMi/pegasus-go-client/rpc"
+ "github.com/apache/incubator-pegasus/go-client/idl/admin"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/cmd"
+ "github.com/apache/incubator-pegasus/go-client/idl/radmin"
+ "github.com/apache/incubator-pegasus/go-client/idl/replication"
+ "github.com/apache/incubator-pegasus/go-client/idl/rrdb"
+ "github.com/apache/incubator-pegasus/go-client/pegalog"
+ "github.com/apache/incubator-pegasus/go-client/rpc"
"github.com/apache/thrift/lib/go/thrift"
)
diff --git a/go-client/session/codec_test.go b/go-client/session/codec_test.go
index 08de365d..63062d11 100644
--- a/go-client/session/codec_test.go
+++ b/go-client/session/codec_test.go
@@ -22,9 +22,9 @@ package session
import (
"testing"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/idl/replication"
- "github.com/XiaoMi/pegasus-go-client/idl/rrdb"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/replication"
+ "github.com/apache/incubator-pegasus/go-client/idl/rrdb"
"github.com/stretchr/testify/assert"
)
diff --git a/go-client/session/header.go b/go-client/session/header.go
index 2c5164cf..0b402841 100644
--- a/go-client/session/header.go
+++ b/go-client/session/header.go
@@ -23,7 +23,7 @@ import (
"encoding/binary"
"fmt"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
)
var thriftHeaderTypeStr = []byte{'T', 'H', 'F', 'T'}
diff --git a/go-client/session/main_test.go b/go-client/session/main_test.go
index ee95694d..cb0e2f54 100644
--- a/go-client/session/main_test.go
+++ b/go-client/session/main_test.go
@@ -23,7 +23,7 @@ import (
"os"
"testing"
- "github.com/XiaoMi/pegasus-go-client/pegalog"
+ "github.com/apache/incubator-pegasus/go-client/pegalog"
)
func TestMain(m *testing.M) {
diff --git a/go-client/session/meta_call.go b/go-client/session/meta_call.go
index bb0cc815..2db6179a 100644
--- a/go-client/session/meta_call.go
+++ b/go-client/session/meta_call.go
@@ -25,7 +25,7 @@ import (
"sync/atomic"
"time"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
)
type metaCallFunc func(context.Context, *metaSession) (metaResponse, error)
diff --git a/go-client/session/meta_session.go
b/go-client/session/meta_session.go
index 0db196c4..7a50ec73 100644
--- a/go-client/session/meta_session.go
+++ b/go-client/session/meta_session.go
@@ -23,10 +23,10 @@ import (
"context"
"sync"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/idl/replication"
- "github.com/XiaoMi/pegasus-go-client/idl/rrdb"
- "github.com/XiaoMi/pegasus-go-client/pegalog"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/replication"
+ "github.com/apache/incubator-pegasus/go-client/idl/rrdb"
+ "github.com/apache/incubator-pegasus/go-client/pegalog"
kerrors "k8s.io/apimachinery/pkg/util/errors"
)
diff --git a/go-client/session/meta_session_test.go
b/go-client/session/meta_session_test.go
index d77777c2..d2cbf6cc 100644
--- a/go-client/session/meta_session_test.go
+++ b/go-client/session/meta_session_test.go
@@ -25,7 +25,7 @@ import (
"testing"
"time"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
"github.com/fortytw2/leaktest"
"github.com/stretchr/testify/assert"
)
diff --git a/go-client/session/radmin_rpc_types.go
b/go-client/session/radmin_rpc_types.go
index d29485c0..55e840f7 100644
--- a/go-client/session/radmin_rpc_types.go
+++ b/go-client/session/radmin_rpc_types.go
@@ -23,8 +23,8 @@ import (
"context"
"fmt"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/idl/radmin"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/radmin"
)
// QueryDiskInfo is auto-generated
diff --git a/go-client/session/replica_session.go
b/go-client/session/replica_session.go
index b529b58c..09de6e6e 100644
--- a/go-client/session/replica_session.go
+++ b/go-client/session/replica_session.go
@@ -23,8 +23,8 @@ import (
"context"
"sync"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/idl/rrdb"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/rrdb"
kerrors "k8s.io/apimachinery/pkg/util/errors"
)
diff --git a/go-client/session/session.go b/go-client/session/session.go
index 3b53a125..034d91c9 100644
--- a/go-client/session/session.go
+++ b/go-client/session/session.go
@@ -27,9 +27,9 @@ import (
"sync/atomic"
"time"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/pegalog"
- "github.com/XiaoMi/pegasus-go-client/rpc"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/pegalog"
+ "github.com/apache/incubator-pegasus/go-client/rpc"
"gopkg.in/tomb.v2"
)
diff --git a/go-client/session/session_test.go
b/go-client/session/session_test.go
index 9ae1ac8b..8ec3e52c 100644
--- a/go-client/session/session_test.go
+++ b/go-client/session/session_test.go
@@ -28,11 +28,11 @@ import (
"testing"
"time"
- "github.com/XiaoMi/pegasus-go-client/idl/base"
- "github.com/XiaoMi/pegasus-go-client/idl/replication"
- "github.com/XiaoMi/pegasus-go-client/idl/rrdb"
- "github.com/XiaoMi/pegasus-go-client/pegalog"
- "github.com/XiaoMi/pegasus-go-client/rpc"
+ "github.com/apache/incubator-pegasus/go-client/idl/base"
+ "github.com/apache/incubator-pegasus/go-client/idl/replication"
+ "github.com/apache/incubator-pegasus/go-client/idl/rrdb"
+ "github.com/apache/incubator-pegasus/go-client/pegalog"
+ "github.com/apache/incubator-pegasus/go-client/rpc"
"github.com/apache/thrift/lib/go/thrift"
"github.com/fortytw2/leaktest"
"github.com/stretchr/testify/assert"
diff --git a/go-client/session/session_timeout_test.go
b/go-client/session/session_timeout_test.go
index 8574be1b..ba383d15 100644
--- a/go-client/session/session_timeout_test.go
+++ b/go-client/session/session_timeout_test.go
@@ -26,7 +26,7 @@ import (
"testing"
"time"
- "github.com/XiaoMi/pegasus-go-client/rpc"
+ "github.com/apache/incubator-pegasus/go-client/rpc"
"github.com/fortytw2/leaktest"
"github.com/stretchr/testify/assert"
)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
