You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pegasus.apache.org by la...@apache.org on 2022/05/26 02:55:55 UTC
[incubator-pegasus] 01/01: chore(go-client): Merge go-client from XiaoMi/pegasus-go-client
This is an automated email from the ASF dual-hosted git repository.
laiyingchun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
commit 6c4c52a599ae5e3178d95526c2b27cabad9bc586
Merge: d6027a4f 86008c56
Author: Yingchun Lai <ac...@gmail.com>
AuthorDate: Thu May 26 10:55:47 2022 +0800
chore(go-client): Merge go-client from XiaoMi/pegasus-go-client
.github/workflows/lint_and_test_go-client.yml | 69 +
.licenserc.yaml | 6 +-
go-client/.golangci.yml | 26 +
go-client/Makefile | 32 +
go-client/README.md | 87 +
go-client/admin/client.go | 134 +
go-client/admin/client_test.go | 140 +
go-client/admin/remote_cmd_client.go | 66 +
go-client/admin/remote_cmd_client_test.go | 37 +
go-client/codecov.yml | 21 +
go-client/docs/how_to_add_new_interface.md | 66 +
go-client/example/full_scan.md | 112 +
go-client/example/main.go | 88 +
go-client/example/pegasus-client-config.json | 7 +
go-client/generator/admin.csv | 26 +
go-client/generator/main.go | 214 +
go-client/generator/radmin.csv | 3 +
go-client/go.mod | 35 +
go-client/go.sum | 120 +
go-client/idl/admin.thrift | 763 +
go-client/idl/admin/GoUnusedProtection__.go | 6 +
go-client/idl/admin/admin-consts.go | 25 +
go-client/idl/admin/admin.go | 20605 ++++++++++++++++++++
go-client/idl/base.thrift | 33 +
go-client/idl/base/GoUnusedProtection__.go | 6 +
go-client/idl/base/blob.go | 54 +
go-client/idl/base/dsn_err_string.go | 121 +
go-client/idl/base/error_code.go | 169 +
go-client/idl/base/gpid.go | 53 +
go-client/idl/base/gpid_test.go | 52 +
go-client/idl/base/rocskdb_err_string.go | 44 +
go-client/idl/base/rpc_address.go | 74 +
go-client/idl/base/rpc_address_test.go | 44 +
go-client/idl/cmd.thrift | 30 +
go-client/idl/cmd/GoUnusedProtection__.go | 6 +
go-client/idl/cmd/cmd-consts.go | 23 +
go-client/idl/cmd/cmd.go | 536 +
go-client/idl/radmin.thrift | 99 +
go-client/idl/radmin/GoUnusedProtection__.go | 6 +
go-client/idl/radmin/radmin-consts.go | 25 +
go-client/idl/radmin/radmin.go | 2353 +++
go-client/idl/replication.thrift | 58 +
go-client/idl/replication/GoUnusedProtection__.go | 6 +
go-client/idl/replication/replication-consts.go | 25 +
go-client/idl/replication/replication.go | 1135 ++
go-client/idl/rrdb.thrift | 293 +
go-client/idl/rrdb/GoUnusedProtection__.go | 6 +
go-client/idl/rrdb/rrdb-consts.go | 27 +
go-client/idl/rrdb/rrdb.go | 10824 ++++++++++
go-client/integration/failover-test/main.go | 73 +
go-client/pegalog/logger.go | 84 +
go-client/pegalog/logrus_logger.go | 69 +
go-client/pegasus/check_and_set.go | 76 +
go-client/pegasus/client.go | 120 +
go-client/pegasus/client_test.go | 162 +
go-client/pegasus/config.go | 25 +
go-client/pegasus/error.go | 89 +
go-client/pegasus/error_test.go | 82 +
go-client/pegasus/filter.go | 39 +
go-client/pegasus/main_test.go | 33 +
go-client/pegasus/op/check_and_set.go | 76 +
go-client/pegasus/op/del.go | 56 +
go-client/pegasus/op/get.go | 61 +
go-client/pegasus/op/incr.go | 61 +
go-client/pegasus/op/multidel.go | 63 +
go-client/pegasus/op/multiget.go | 89 +
go-client/pegasus/op/multiset.go | 84 +
go-client/pegasus/op/op.go | 34 +
go-client/pegasus/op/set.go | 73 +
go-client/pegasus/op/sortkey_count.go | 52 +
go-client/pegasus/op/ttl.go | 62 +
go-client/pegasus/op/utils.go | 137 +
go-client/pegasus/retry_failover.go | 53 +
go-client/pegasus/retry_failover_test.go | 86 +
go-client/pegasus/scan_test.go | 332 +
go-client/pegasus/scanner.go | 317 +
go-client/pegasus/table_connector.go | 823 +
go-client/pegasus/table_connector_leak_test.go | 45 +
go-client/pegasus/table_connector_test.go | 860 +
go-client/pegasus/util.go | 68 +
go-client/rpc/codec.go | 32 +
go-client/rpc/main/echo.go | 66 +
go-client/rpc/main_test.go | 33 +
go-client/rpc/rpc_conn.go | 233 +
go-client/rpc/rpc_conn_test.go | 173 +
go-client/rpc/stream_in.go | 96 +
go-client/rpc/stream_out.go | 53 +
go-client/rpc/stream_test.go | 74 +
go-client/rpc/utils.go | 46 +
go-client/session/addr.go | 56 +
go-client/session/addr_test.go | 54 +
go-client/session/admin_rpc_types.go | 678 +
go-client/session/codec.go | 495 +
go-client/session/codec_test.go | 75 +
go-client/session/header.go | 69 +
go-client/session/main_test.go | 33 +
go-client/session/meta_call.go | 135 +
go-client/session/meta_session.go | 145 +
go-client/session/meta_session_test.go | 128 +
go-client/session/radmin_rpc_types.go | 76 +
go-client/session/replica_session.go | 242 +
go-client/session/replica_session_test.go | 69 +
go-client/session/session.go | 413 +
go-client/session/session_test.go | 402 +
go-client/session/session_timeout_test.go | 86 +
go-client/test.sh | 47 +
106 files changed, 47081 insertions(+), 2 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pegasus.apache.org
For additional commands, e-mail: commits-help@pegasus.apache.org