This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/maven/java-client/org.apache.thrift-libthrift-0.14.0
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
discard 1953b8d6 build(deps): bump libthrift from 0.11.0 to 0.14.0 in
/java-client
add 719f39c8 add README
add fee58d62 first checkin
add 3f8e4cef add example in readme
add 32f7d012 define a serializer trait for convenient use
add 61fa1c6c update async
add 51327a9b del hashKey before testing
add d862b842 any ref serializer
add 98083722 use 1.11.2-thrift-0.11.0-inlined
add 27617dd4 support incr
add 932c7613 remove
src/main/scala/com/xiaomi/infra/pegasus/scalaclient/AnyRefSerializer.scala
add 5121fef0 Merge pull request #1 from XiaoMi/github
add ed650276 update build config and add test (#2)
add 8498aa11 fix: update create client api for lastest java client version
(#5)
add 88491ed7 feat: support open table with `tableOptions` (#6)
add ec278866 fix: update git action ci (#7)
add c1ea4f41 chore: prepare to merge into incubator-pegasus (#8)
add 681f2a03 Merge pegasus-scala-client repo
add 0db87f70 scala client conform to apache style
add 3dfc3658 Merge pull request #966 from XiaoMi/pegasus-scala-client
add 2fb0a986 Initial commit
add b0080a4d init python client
add c3f473dd fix a rpc_address decode bug & add some test cases
add 241682ee fix README
add 81923e86 fix a rpc_address decode bug & add some test cases
add e4cfe4d5 Update README.md
add e62e4157 fix scan endless loop bug & uniform return code
add 68bcf4ca update README
add fb3752ae update README
add 3d55fc91 fix README
add 05fea4ee remove extra error code usage
add cb1a9133 Merge pull request #1 from acelyc111/bugfix
add 3dcf6d29 add basic doc for API class and functions
add d76d4855 fix timeout bug
add 2f826825 change code structure for pypi
add 1ef37777 remove some commented code, revert meaningless test path
change
add 45e485c6 Merge pull request #2 from acelyc111/master
add 835e8e37 modify setup license type
add 372b9222 Merge pull request #3 from acelyc111/master
add 3cc266fd modify installation method
add 26f1f18f fix crc64 bug
add 5a67e4c4 new version
add 2e1d8f78 add API: add multi_get with option (#5)
add fad5487d Update README.md
add f3ec21d2 *: add more API docstring (#6)
add 1b351774 fix wrong partition_hash (#10)
add 21d398a9 BaseSession: rename _reqs (#11)
add ffa9567b [bugfix] Fix a typo (#14)
add 61007fcf feat(python3): python client compat with python3 (#15)
add f8e5d0bc Python3 client support binary write (#20)
add 1bcde583 fix(python3): fix wrong partition_hash in py3 client (#21)
add 57beb623 fix(python3): fix tests (#26)
add 012bc55d feat(python3): add thrift idl files (#27)
add 8ebc01d0 feat(python3): adapt partition split (#28)
add 3a444bca prepare to merge into incubator-pegasus (#32)
add f82f80f2 merge pegasus-python-client repo
add 167129f5 python client conform to apache style
add da9f3ebe Merge pull request #967 from XiaoMi/pegasus-python-client
add 82e35ce7 feat(bulk_load): support clear last bulk load state interface
(#968)
add b656d930 feat(bulk_load): add bulk load ingestion progress for shell
and admin-cli (#975)
add cedb819d feat: add app drop interface to the java client (#973)
add d6027a4f fix(python-cient): python3 pass str value but not bytes (#977)
add 79e11c1c Initial commit of pegasus go client
add 38d1a627 numerous fixes
add 6bab119d [go-client] bug fix in response reading.
add ac6e737f [go-client] implement "session-auto-reconnect"
add ab142eb7 [go-client] multiple fixes
add c3b10e83 [go-client] decorated PError with gpid and replica address
add 8b9aaebb temp commit
add a5013f2e [go-client] upgrade thrift to 0.11.0 and support multi_get
and multi-del
add 8308728b [go-client] remove dangerous panics when unmarshal response,
add 39a2e31d [go-client] remove version contraints on test-import
add ac43510e [go-client] add thrift 0.11.0 as a must-dependency.
add a24ef35d [go-client] add example program
add 56894cc9 [go-client] define filter type using rrdb.FilterType
add 8edfde1d [go-client] increase dial interval from 2 sec to 60 secs.
add f26c874c [go-client] updateConf: return error when responded
configuration contains wrong data.
add c88d0c59 [go-client] fix serious bug in low level RPC implementation.
add c392fcfd Merge pull request #1 from neverchanje/master
add b2d39e2d remove replica connections when meta server removes them in
configuration.
add 4fdd70b0 add unit test for procedure handling QueryCfgResponse
add 4981c037 Merge pull request #3 from neverchanje/master
add 328633c3 bugfix: revert pr#3 and fix connections being closed during
TableConnector.Close.
add ef019bb7 Merge pull request #6 from neverchanje/master
add 8af47961 increase conf update timeout to protect meta server from
heavy workload.
add fc58422b tableConnector: fix configuration update strategy
add 53795671 Merge pull request #7 from neverchanje/master
add ef3e6715 *: improve rpc throughput && bug fixes (#10)
add 633b02d4 session: fetch table configuration when connection to replica
broke down (#11)
add cfc877b3 API: introduce TTL and MultiSet (#13)
add ca26b86e API: introduce Scan (#14)
add 2cfba839 fix no leader in meta servers (#15)
add 5db38c20 ttl: fix the return value of ttl & ttl_test (#16)
add 3b67dfe1 *: refactor session interface and add pegasus2 API (#17)
add 7fad932f *: handle rocksdb error (#18)
add 2797a37b rpc: decrease default read buffer to 4KB (#19)
add 59b240cc pegasus2/session: fix bug when receiving a stale response
(#20)
add 28d9c4c8 api: implement SortKeyCount and CheckAndSet, support SetTTL
(#22)
add 854ff314 table_connector: add more comments on API & fixes on
multi-get (#23)
add 122805ab table_connector: add support for reverse scan of
MultiGetRange (#24)
add cd63ac3f table_connector: fix validation on empty/nil input (#25)
add 95e7fd7b pegasus: suppress warnings of staticcheck, govet, golint (#26)
add 9400942c bugfix: assign logger while initializing PegasusCodec (#27)
add 5d3959e7 fix hang problem when rpc session is rejected/closed by meta
(#28)
add 337e0ea1 Revert "fix hang problem when rpc session is rejected/closed
by meta" (#30)
add ea28031f deps: upgrade thrift to 0.13.0 (#32)
add 70cdcddb API: implement `Incr` (#33)
add 1b4ee69e test: support travis ci and golangci (#34)
add 8b2e390d feat(api): implement BatchGet (#36)
add a839d77f feat: add metrics for set/multiset/get/multiget latency (#37)
add 5c423ba0 fix: rpc blocked on loopForResponse (#38)
add f3691d0c fix: revert prometheus to prevent build failure on glide (#39)
add 81bbcf08 test: run unit tests on travis (#40)
add 4ce6f7a4 feat: add flags for latency tracing (#41)
add 8bc2b70a feat: use logrus as default logger (#42)
add 68dbdfc9 doc: add docs and example for customizing logger (#44)
add 3ec0a08e fix: reduce connection polling interval to minimize
connection time (#45)
add bb62534d fix: add error codes that are needed for communication (#46)
add a8922462 fix: add more logs on failure cases, like EOF handling and
meta restart (#47)
add d24caba2 feat: add no_value option for multiget (#48)
add d2c7622b fix: handle cases for replica stop and restart (#49)
add 98cf6996 test: add test for multiget options NoValue and Reverse (#50)
add e2f054e1 doc: add example for full scan (#51)
add 68dacaeb improvement: support extending rpc types and remove pegasus2
(#52)
add 09d44a49 feat: implement meta admin api (#53)
add 6b8d4e85 chore: migrate travis to github action (#55)
add 0f7b3a24 feat: support get app envs in admin ListTables (#54)
add 1192ac56 feat: add thrift interface of duplication (#56)
add 9d107cd8 feat: support resolving hostname for meta addrs (#57)
add 13fcf422 feat: auto-generate meta rpc code (#58)
add 921fbbd1 feat: generate admin rpc of replica and meta (#59)
add 273d6e44 feat: add rpc ack code (#60)
add 86d40835 feat: support remote command client (#61)
add 45f30cd5 feat(radmin): handle error in response of radmin API (#62)
add 60f98674 fix: gpid serialize error (#63)
add 4de07b39 feat: add recall rpc code (#64)
add d3b9a03a feat: call remote command based on existing session (#65)
add 6285b0da feat: add QueryBackupPolicy interface (#69)
add 39f8cc97 fix: fix duplicate when full_scan with filter (#70)
add 4fb12f4b fix: auto fail on network r/w timeout (#67)
add 8950c634 fix: admin api created table must be available (#71)
add d6ef3692 test: refactor scan test and make it easy to pass (#73)
add aa7e70fb test: instrument create table test with more messages (#75)
add c353216c refactor: implement each rpc as an op (p1) (#74)
add 2d535668 refactor: implement each rpc as an op (p2) (#76)
add 997aebff refactor: implement each rpc as an op (p3) (#77)
add 4d923418 fix: retry on replica failover until context timeout (#78)
add f3146e70 fix: fix timer leak (#79)
add 89707a7d build: shade dependencies of thrift (#80)
add 4127db08 fix: logging in session connect (#81)
add 358b58b3 fix: block on session close (#82)
add 2ce9b73e feat: introduce balance meta api (#83)
add f3b6b08b feat: support construction of base.RPCAddress (#84)
add 50cb769c docs: add manual for adding rpc types (#85)
add 1c108640 fix: scanner.next() won't automatically recover when server
side not return ERR_OK (#86)
add 3af6e8b3 feat(meta_rpc): introduce backup/restore rpcs (#87)
add 0a0602e2 feat: add rrdb.thrift and replication.thrift (#93)
add 40afb544 feat: add ttl validator for some interfaces (#90)
add 0b3f618c feat(split): part1 - fill valid partition_hash in header (#91)
add 54736e40 feat(split): part2 - support checkHash for scanner (#94)
add f2c7f67f feat(split): part3 - add split related error code (#95)
add b8a75c1e feat(split): part4 - handle partition count changed (#96)
add 2e0a0677 feat: add partition split related rpc (#97)
add 2702bf2b fix: fix split related structure (#98)
add 2a615cf3 feat: support add disk rpc thrift (#99)
add ae3787ff feat: add bulk load related structures (#101)
add 79d43ccd feat: handle ERR_DISK_INSUFFICIENT error (#102)
add 5ae2deb7 fix: rpc will failed when server side enable drop timeout
request feature (#104)
add 238f1313 fix: the timeout should use UnixNano to compute
add 0e7f4943 feat: add manual compaction related rpc (#107)
add a3a3036e chore: prepare to merge into incubator-pegasus (#108)
add bf40fa89 feat: add clear bulk load rpc (#109)
add 3b9df16a chore: Merge go-client from XiaoMi/pegasus-go-client
add 86008c56 chore(go-client): Merge go-client from
XiaoMi/pegasus-go-client: adapt changes
add 6c4c52a5 chore(go-client): Merge go-client from
XiaoMi/pegasus-go-client
add 8cf31c7d build(deps): bump libthrift from 0.11.0 to 0.14.0 in
/java-client
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (1953b8d6)
\
N -- N -- N
refs/heads/dependabot/maven/java-client/org.apache.thrift-libthrift-0.14.0
(8cf31c7d)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
..._test_pegic.yml => lint_and_test_go-client.yml} | 31 +-
...{test_java-client.yml => test_scala-client.yml} | 8 +-
.gitignore | 116 +
.licenserc.yaml | 6 +-
README.md | 2 +-
admin-cli/executor/bulk_load.go | 47 +
.../CMakeLists.txt => go-client/.golangci.yml | 15 +-
{admin-cli => go-client}/Makefile | 16 +-
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 +
.../admin/remote_cmd_client_test.go | 30 +-
.../CMakeLists.txt => go-client/codecov.yml | 10 +-
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 +
{pegic => go-client}/go.mod | 25 +-
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 +++++++++++++++++++
.../brief_stat.h => go-client/idl/base.thrift | 15 +-
go-client/idl/base/GoUnusedProtection__.go | 6 +
.../use_table.go => go-client/idl/base/blob.go | 31 +-
go-client/idl/base/dsn_err_string.go | 121 +
go-client/idl/base/error_code.go | 169 +
.../use_table.go => go-client/idl/base/gpid.go | 32 +-
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 +
.../idl/base/rpc_address_test.go | 28 +-
.../brief_stat.h => go-client/idl/cmd.thrift | 12 +-
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 +++
{java-client => go-client}/idl/replication.thrift | 5 +-
go-client/idl/replication/GoUnusedProtection__.go | 6 +
go-client/idl/replication/replication-consts.go | 25 +
go-client/idl/replication/replication.go | 1135 +
{java-client => go-client}/idl/rrdb.thrift | 34 +-
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 +
.../brief_stat.h => go-client/pegasus/config.go | 7 +-
go-client/pegasus/error.go | 89 +
go-client/pegasus/error_test.go | 82 +
.../cmd/init.go => go-client/pegasus/filter.go | 29 +-
.../options.go => go-client/pegasus/main_test.go | 16 +-
go-client/pegasus/op/check_and_set.go | 76 +
.../use_table.go => go-client/pegasus/op/del.go | 37 +-
.../disk_migrate.go => go-client/pegasus/op/get.go | 52 +-
.../pegasus/op/incr.go | 52 +-
.../pegasus/op/multidel.go | 54 +-
go-client/pegasus/op/multiget.go | 89 +
go-client/pegasus/op/multiset.go | 84 +
.../toolkits/log.go => go-client/pegasus/op/op.go | 27 +-
go-client/pegasus/op/set.go | 73 +
.../pegasus/op/sortkey_count.go | 35 +-
.../disk_migrate.go => go-client/pegasus/op/ttl.go | 53 +-
go-client/pegasus/op/utils.go | 137 +
.../del.go => go-client/pegasus/retry_failover.go | 39 +-
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 +
.../pegasus/table_connector_leak_test.go | 31 +-
go-client/pegasus/table_connector_test.go | 860 +
.../pegasus/util.go | 59 +-
.../client/options.go => go-client/rpc/codec.go | 19 +-
go-client/rpc/main/echo.go | 66 +
.../options.go => go-client/rpc/main_test.go | 16 +-
go-client/rpc/rpc_conn.go | 233 +
go-client/rpc/rpc_conn_test.go | 173 +
go-client/rpc/stream_in.go | 96 +
.../use_table.go => go-client/rpc/stream_out.go | 38 +-
go-client/rpc/stream_test.go | 74 +
.../use_table.go => go-client/rpc/utils.go | 31 +-
.../use_table.go => go-client/session/addr.go | 37 +-
.../context.go => go-client/session/addr_test.go | 49 +-
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 +
.../options.go => go-client/session/main_test.go | 16 +-
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 +
pegic/check_and_format.sh => go-client/test.sh | 33 +-
java-client/idl/meta_admin.thrift | 17 +
java-client/idl/rrdb.thrift | 1 +
.../main/java/org/apache/pegasus/apps/meta.java | 1188 +-
.../apache/pegasus/client/PegasusAdminClient.java | 24 +
.../client/PegasusAdminClientInterface.java | 2 +
...te_app_operator.java => drop_app_operator.java} | 24 +-
...st.java => configuration_drop_app_request.java} | 82 +-
...e.java => configuration_drop_app_response.java} | 195 +-
...ate_app_response.java => drop_app_options.java} | 335 +-
.../org/apache/pegasus/rpc/async/MetaSession.java | 3 +
.../org/apache/pegasus/client/TestAdminClient.java | 61 +-
python-client/README.md | 83 +
python-client/__init__.py | 17 +
{java-client => python-client}/idl/base.thrift | 1 +
.../idl/replication.thrift | 1 +
{java-client => python-client}/idl/rrdb.thrift | 29 +-
python-client/pypegasus/__init__.py | 21 +
python-client/pypegasus/base/__init__.py | 18 +
python-client/pypegasus/base/constants.py | 28 +
python-client/pypegasus/base/ttypes.py | 352 +
.../pypegasus/logger.conf | 29 +-
python-client/pypegasus/operate/__init__.py | 18 +
python-client/pypegasus/operate/packet.py | 274 +
python-client/pypegasus/pgclient.py | 1053 +
python-client/pypegasus/replication/__init__.py | 18 +
python-client/pypegasus/replication/constants.py | 28 +
python-client/pypegasus/replication/replication.py | 23 +
python-client/pypegasus/replication/ttypes.py | 533 +
python-client/pypegasus/rrdb/__init__.py | 18 +
python-client/pypegasus/rrdb/constants.py | 28 +
python-client/pypegasus/rrdb/meta.py | 258 +
python-client/pypegasus/rrdb/rrdb.py | 2625 +++
python-client/pypegasus/rrdb/ttypes.py | 2824 +++
python-client/pypegasus/transport/__init__.py | 18 +
python-client/pypegasus/transport/compat.py | 38 +
python-client/pypegasus/transport/protocol.py | 192 +
python-client/pypegasus/utils/__init__.py | 18 +
python-client/pypegasus/utils/tools.py | 115 +
python-client/sample.py | 150 +
python-client/setup.py | 44 +
python-client/tests/__init__.py | 19 +
python-client/tests/test_basics.py | 673 +
python-client/tests/test_benchmark.py | 72 +
python-client/tests/test_integration.py | 294 +
rdsn | 2 +-
scala-client/README.md | 55 +
scala-client/build.sbt | 59 +
.../project/build.properties | 7 +-
.../project/plugins.sbt | 4 +-
{java-client => scala-client}/scripts/ci-test.sh | 28 +-
.../scripts/format-all.sh | 10 +-
.../org/apache/pegasus/scalaclient/Models.scala | 73 +
.../apache/pegasus/scalaclient/PegasusUtil.scala | 150 +
.../scalaclient/ScalaPegasusAsyncTable.scala | 182 +
.../pegasus/scalaclient/ScalaPegasusClient.scala | 261 +
.../scalaclient/ScalaPegasusClientFactory.scala | 29 +-
.../pegasus/scalaclient/ScalaPegasusTable.scala | 291 +
.../apache/pegasus/scalaclient/Serializer.scala | 97 +
.../org/apache/pegasus/scalaclient/package.scala | 65 +
.../src/test/resources}/log4j.properties | 6 +-
.../src/test/resources/pegasus.properties | 12 +-
.../org/apache/pegasus/scalaclient/TableSpec.scala | 308 +
src/shell/commands.h | 2 +
src/shell/commands/bulk_load.cpp | 64 +-
src/shell/main.cpp | 3 +
175 files changed, 59012 insertions(+), 1019 deletions(-)
copy .github/workflows/{lint_and_test_pegic.yml =>
lint_and_test_go-client.yml} (76%)
copy .github/workflows/{test_java-client.yml => test_scala-client.yml} (88%)
copy src/redis_protocol/CMakeLists.txt => go-client/.golangci.yml (86%)
copy {admin-cli => go-client}/Makefile (62%)
create mode 100644 go-client/README.md
create mode 100644 go-client/admin/client.go
create mode 100644 go-client/admin/client_test.go
create mode 100644 go-client/admin/remote_cmd_client.go
copy admin-cli/executor/toolkits/log.go =>
go-client/admin/remote_cmd_client_test.go (70%)
copy src/redis_protocol/CMakeLists.txt => go-client/codecov.yml (89%)
create mode 100644 go-client/docs/how_to_add_new_interface.md
create mode 100644 go-client/example/full_scan.md
create mode 100644 go-client/example/main.go
create mode 100644 go-client/example/pegasus-client-config.json
create mode 100644 go-client/generator/admin.csv
create mode 100644 go-client/generator/main.go
create mode 100644 go-client/generator/radmin.csv
copy {pegic => go-client}/go.mod (59%)
create mode 100644 go-client/go.sum
create mode 100644 go-client/idl/admin.thrift
create mode 100644 go-client/idl/admin/GoUnusedProtection__.go
create mode 100644 go-client/idl/admin/admin-consts.go
create mode 100644 go-client/idl/admin/admin.go
copy src/server/brief_stat.h => go-client/idl/base.thrift (89%)
create mode 100644 go-client/idl/base/GoUnusedProtection__.go
copy admin-cli/executor/use_table.go => go-client/idl/base/blob.go (67%)
create mode 100644 go-client/idl/base/dsn_err_string.go
create mode 100644 go-client/idl/base/error_code.go
copy admin-cli/executor/use_table.go => go-client/idl/base/gpid.go (63%)
create mode 100644 go-client/idl/base/gpid_test.go
create mode 100644 go-client/idl/base/rocskdb_err_string.go
create mode 100644 go-client/idl/base/rpc_address.go
copy admin-cli/executor/recall_table.go =>
go-client/idl/base/rpc_address_test.go (66%)
copy src/server/brief_stat.h => go-client/idl/cmd.thrift (84%)
create mode 100644 go-client/idl/cmd/GoUnusedProtection__.go
create mode 100644 go-client/idl/cmd/cmd-consts.go
create mode 100644 go-client/idl/cmd/cmd.go
create mode 100644 go-client/idl/radmin.thrift
create mode 100644 go-client/idl/radmin/GoUnusedProtection__.go
create mode 100644 go-client/idl/radmin/radmin-consts.go
create mode 100644 go-client/idl/radmin/radmin.go
copy {java-client => go-client}/idl/replication.thrift (93%)
create mode 100644 go-client/idl/replication/GoUnusedProtection__.go
create mode 100644 go-client/idl/replication/replication-consts.go
create mode 100644 go-client/idl/replication/replication.go
copy {java-client => go-client}/idl/rrdb.thrift (90%)
create mode 100644 go-client/idl/rrdb/GoUnusedProtection__.go
create mode 100644 go-client/idl/rrdb/rrdb-consts.go
create mode 100644 go-client/idl/rrdb/rrdb.go
create mode 100644 go-client/integration/failover-test/main.go
create mode 100644 go-client/pegalog/logger.go
create mode 100644 go-client/pegalog/logrus_logger.go
create mode 100644 go-client/pegasus/check_and_set.go
create mode 100644 go-client/pegasus/client.go
create mode 100644 go-client/pegasus/client_test.go
copy src/server/brief_stat.h => go-client/pegasus/config.go (86%)
create mode 100644 go-client/pegasus/error.go
create mode 100644 go-client/pegasus/error_test.go
copy admin-cli/cmd/init.go => go-client/pegasus/filter.go (59%)
copy admin-cli/client/options.go => go-client/pegasus/main_test.go (80%)
create mode 100644 go-client/pegasus/op/check_and_set.go
copy admin-cli/executor/use_table.go => go-client/pegasus/op/del.go (57%)
copy admin-cli/executor/disk_migrate.go => go-client/pegasus/op/get.go (55%)
copy admin-cli/executor/disk_migrate.go => go-client/pegasus/op/incr.go (53%)
copy admin-cli/executor/disk_migrate.go => go-client/pegasus/op/multidel.go
(50%)
create mode 100644 go-client/pegasus/op/multiget.go
create mode 100644 go-client/pegasus/op/multiset.go
copy admin-cli/executor/toolkits/log.go => go-client/pegasus/op/op.go (71%)
create mode 100644 go-client/pegasus/op/set.go
copy admin-cli/executor/use_table.go => go-client/pegasus/op/sortkey_count.go
(58%)
copy admin-cli/executor/disk_migrate.go => go-client/pegasus/op/ttl.go (54%)
create mode 100644 go-client/pegasus/op/utils.go
copy pegic/executor/del.go => go-client/pegasus/retry_failover.go (54%)
create mode 100644 go-client/pegasus/retry_failover_test.go
create mode 100644 go-client/pegasus/scan_test.go
create mode 100644 go-client/pegasus/scanner.go
create mode 100644 go-client/pegasus/table_connector.go
copy pegic/executor/del.go => go-client/pegasus/table_connector_leak_test.go
(64%)
create mode 100644 go-client/pegasus/table_connector_test.go
copy pegic/executor/partition_index.go => go-client/pegasus/util.go (53%)
copy admin-cli/client/options.go => go-client/rpc/codec.go (62%)
create mode 100644 go-client/rpc/main/echo.go
copy admin-cli/client/options.go => go-client/rpc/main_test.go (81%)
create mode 100644 go-client/rpc/rpc_conn.go
create mode 100644 go-client/rpc/rpc_conn_test.go
create mode 100644 go-client/rpc/stream_in.go
copy admin-cli/executor/use_table.go => go-client/rpc/stream_out.go (58%)
create mode 100644 go-client/rpc/stream_test.go
copy admin-cli/executor/use_table.go => go-client/rpc/utils.go (64%)
copy admin-cli/executor/use_table.go => go-client/session/addr.go (52%)
copy admin-cli/shell/context.go => go-client/session/addr_test.go (51%)
create mode 100644 go-client/session/admin_rpc_types.go
create mode 100644 go-client/session/codec.go
create mode 100644 go-client/session/codec_test.go
create mode 100644 go-client/session/header.go
copy admin-cli/client/options.go => go-client/session/main_test.go (80%)
create mode 100644 go-client/session/meta_call.go
create mode 100644 go-client/session/meta_session.go
create mode 100644 go-client/session/meta_session_test.go
create mode 100644 go-client/session/radmin_rpc_types.go
create mode 100644 go-client/session/replica_session.go
create mode 100644 go-client/session/replica_session_test.go
create mode 100644 go-client/session/session.go
create mode 100644 go-client/session/session_test.go
create mode 100644 go-client/session/session_timeout_test.go
copy pegic/check_and_format.sh => go-client/test.sh (56%)
copy
java-client/src/main/java/org/apache/pegasus/operator/{create_app_operator.java
=> drop_app_operator.java} (68%)
copy
java-client/src/main/java/org/apache/pegasus/replication/{configuration_create_app_request.java
=> configuration_drop_app_request.java} (86%)
copy
java-client/src/main/java/org/apache/pegasus/replication/{configuration_create_app_response.java
=> configuration_drop_app_response.java} (65%)
copy
java-client/src/main/java/org/apache/pegasus/replication/{configuration_create_app_response.java
=> drop_app_options.java} (53%)
create mode 100644 python-client/README.md
create mode 100644 python-client/__init__.py
copy {java-client => python-client}/idl/base.thrift (99%)
copy {java-client => python-client}/idl/replication.thrift (99%)
copy {java-client => python-client}/idl/rrdb.thrift (91%)
create mode 100644 python-client/pypegasus/__init__.py
create mode 100644 python-client/pypegasus/base/__init__.py
create mode 100644 python-client/pypegasus/base/constants.py
create mode 100644 python-client/pypegasus/base/ttypes.py
copy java-client/configuration/pegasus.properties =>
python-client/pypegasus/logger.conf (68%)
create mode 100644 python-client/pypegasus/operate/__init__.py
create mode 100644 python-client/pypegasus/operate/packet.py
create mode 100644 python-client/pypegasus/pgclient.py
create mode 100644 python-client/pypegasus/replication/__init__.py
create mode 100644 python-client/pypegasus/replication/constants.py
create mode 100644 python-client/pypegasus/replication/replication.py
create mode 100644 python-client/pypegasus/replication/ttypes.py
create mode 100644 python-client/pypegasus/rrdb/__init__.py
create mode 100644 python-client/pypegasus/rrdb/constants.py
create mode 100644 python-client/pypegasus/rrdb/meta.py
create mode 100644 python-client/pypegasus/rrdb/rrdb.py
create mode 100644 python-client/pypegasus/rrdb/ttypes.py
create mode 100644 python-client/pypegasus/transport/__init__.py
create mode 100644 python-client/pypegasus/transport/compat.py
create mode 100644 python-client/pypegasus/transport/protocol.py
create mode 100644 python-client/pypegasus/utils/__init__.py
create mode 100644 python-client/pypegasus/utils/tools.py
create mode 100755 python-client/sample.py
create mode 100644 python-client/setup.py
create mode 100644 python-client/tests/__init__.py
create mode 100644 python-client/tests/test_basics.py
create mode 100644 python-client/tests/test_benchmark.py
create mode 100644 python-client/tests/test_integration.py
create mode 100644 scala-client/README.md
create mode 100644 scala-client/build.sbt
copy src/geo/CMakeLists.txt => scala-client/project/build.properties (91%)
copy src/test/kill_test/killer_registry.h => scala-client/project/plugins.sbt
(93%)
copy {java-client => scala-client}/scripts/ci-test.sh (70%)
copy src/redis_protocol/CMakeLists.txt => scala-client/scripts/format-all.sh
(86%)
mode change 100644 => 100755
create mode 100644
scala-client/src/main/scala/org/apache/pegasus/scalaclient/Models.scala
create mode 100644
scala-client/src/main/scala/org/apache/pegasus/scalaclient/PegasusUtil.scala
create mode 100644
scala-client/src/main/scala/org/apache/pegasus/scalaclient/ScalaPegasusAsyncTable.scala
create mode 100644
scala-client/src/main/scala/org/apache/pegasus/scalaclient/ScalaPegasusClient.scala
copy java-client/src/main/java/org/apache/pegasus/client/FilterType.java =>
scala-client/src/main/scala/org/apache/pegasus/scalaclient/ScalaPegasusClientFactory.scala
(64%)
create mode 100644
scala-client/src/main/scala/org/apache/pegasus/scalaclient/ScalaPegasusTable.scala
create mode 100644
scala-client/src/main/scala/org/apache/pegasus/scalaclient/Serializer.scala
create mode 100644
scala-client/src/main/scala/org/apache/pegasus/scalaclient/package.scala
copy {java-client/configuration =>
scala-client/src/test/resources}/log4j.properties (97%)
copy .gitmodules => scala-client/src/test/resources/pegasus.properties (79%)
create mode 100644
scala-client/src/test/scala/org/apache/pegasus/scalaclient/TableSpec.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
