You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pegasus.apache.org by gi...@apache.org on 2022/05/26 02:57:31 UTC
[incubator-pegasus] branch dependabot/pip/python-client/twisted-22.4.0 updated (076415ea -> 791b3c47)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/pip/python-client/twisted-22.4.0
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
omit 076415ea build(deps): bump twisted from 21.2.0 to 22.4.0 in /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 791b3c47 build(deps): bump twisted from 21.2.0 to 22.4.0 in /python-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 (076415ea)
\
N -- N -- N refs/heads/dependabot/pip/python-client/twisted-22.4.0 (791b3c47)
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 +-
.licenserc.yaml | 6 +-
admin-cli/executor/bulk_load.go | 47 +
.../build.properties => go-client/.golangci.yml | 13 +-
{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 +-
.../build.properties => go-client/codecov.yml | 8 +-
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 +++
.../idl/replication.thrift | 4 +-
go-client/idl/replication/GoUnusedProtection__.go | 6 +
go-client/idl/replication/replication-consts.go | 25 +
go-client/idl/replication/replication.go | 1135 +
{python-client => go-client}/idl/rrdb.thrift | 5 +-
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 +
.../scripts/ci-test.sh => go-client/test.sh | 42 +-
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/pypegasus/pgclient.py | 6 +-
rdsn | 2 +-
src/shell/commands.h | 2 +
src/shell/commands/bulk_load.cpp | 64 +-
src/shell/main.cpp | 3 +
123 files changed, 47417 insertions(+), 920 deletions(-)
copy .github/workflows/{lint_and_test_pegic.yml => lint_and_test_go-client.yml} (76%)
copy scala-client/project/build.properties => 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 scala-client/project/build.properties => 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 {python-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 {python-client => go-client}/idl/rrdb.thrift (98%)
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 scala-client/scripts/ci-test.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%)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pegasus.apache.org
For additional commands, e-mail: commits-help@pegasus.apache.org