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 <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
