This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/pip/python-client/cryptography-42.0.4
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
discard cc888d868 build(deps): bump cryptography from 3.2 to 42.0.4 in
/python-client
add b8573427e fix(cmake): increase the minimum required version of cmake
to 3.24.0 (#1928)
add 2c9b5ed5d refactor(ddl_client): Simplify app_name validate code (#1931)
add 1c4fcbb2d refactor(meta_store): Reduce the dependency of meta_store
(#1932)
add 0942c4aa8 feat(java-client): Introduce exponentialBackoff retry
mechanism (#1822)
add 057b77a24 refactor(replica): Unify some unique variables to reduce
redundances (#1933)
add 32934bdbb refactor(partition_resolver): Move get_partition_index() as
a public accessed function (#1934)
add f78e0dcc4 refactor(replica_stub): Encapsulate a public accessable
validate_replica_dir() (#1935)
add b0e4c596d refactor(go-client): refactor admin APIs for meta by
reflection (#1929)
add 4e76061a9 fix(partition_split): Fix the missing garbage partition
(#1936)
add 7a5593fa4 fix(image): enable verifying certificate for CentOS 7 (#1941)
add 2bcdaf51b feat(go-client): add ListNodes as admin API for meta (#1939)
add c1788c3db fix: fix recall_app with default app_name (#1942)
add 802d2c257 feat(FQDN): replace rpc_address to host_prot for function &
add host_port on thrift struct (#1658)
add 42bf2dbb0 feat(local_partition_split): Add local_partition_split CLI
tool (#1930)
add 261c95ec4 feat(go-client): Add new HostPort struct according to IDL
(#1946)
add 38fa72ecf feat(collector): introduce the hotspot detector into
go-collector (#1943)
add 1c727a048 fix(balance): Distinguish cluster balanced or collecting
balance info interruptted (#1951)
add 97f7c3032 fix(duplication): dup request is rejected by remote cluster
due to `max_allowed_write_size` (#1841)
add 17cb00266 fix(duplication): prevent plog files from being removed by
GC while they are being checked by duplication (#1597)
add 671186cc9 feat(duplication): allow remote app name to be specified for
duplication (#1960)
add 0bfe78023 refactor(duplication): move
get_all_replicas/get_all_primaries from duplication_sync_timer to replica_stub
(#1967)
add 937e33716 fix(duplication): get duplication manager as shared_ptr in
case raw pointer has been reset to null (#1968)
add f5e1b8130 fix(duplication): failed to start duplication after source
replica servers exit due to missing duplicating status in .app-info (#1608)
add bcb92f0fd chore(thirdparty): Bump prometheus-cpp to 1.2.4 (#1966)
add e7b9b831e refactor(HTTP): Improve the help description of HTTP APIs
(#1959)
add a40c768f9 refactor(configs): Clearify more configs (#1955)
add fe6f1f054 feat(FQDN): Use chkpt_<host>_<port> as the backup path
(#1958)
add 2d6874826 refactor(remote_commands): Simplify the command register
process (#1912)
add baa4840e5 refactor(FQDN): Use const reference to reduce unnecessary
object copying (#1957)
add 6d720b93a fix(message_ex): fix the crash caused by message_ex::copy()
in server internally (#1938)
add c4481ba2a refator(FQDN): Rename variables to indicate type and remove
useless function (#1953)
add 501583ca6 refactor(FQDN): Make address() and host_port() members
return const reference types (#1952)
add cf8a187f6 refactor(FQDN): Resolve IP from from host:port in tests to
keep consistent (#1950)
add 7a20b5633 refactor(FQDN): resolve host:port to ip:port if -r parameter
is specified (#1954)
add 52e7fee62 build(deps): bump cryptography from 3.2 to 42.0.4 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 (cc888d868)
\
N -- N -- N
refs/heads/dependabot/pip/python-client/cryptography-42.0.4 (52e7fee62)
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:
.github/workflows/lint_and_test_go-client.yml | 2 +-
.licenserc.yaml | 1 -
CMakeLists.txt | 2 +-
collector/avail/detector.go | 4 +-
collector/config.yml | 3 +
.../hotspot/{algo.go => partition_detector.go} | 40 ++
collector/main.go | 27 +-
collector/metrics/metric_collector.go | 4 +-
docker/pegasus-build-env/centos7/Dockerfile | 1 +
go-client/admin/client.go | 212 ++++--
go-client/admin/client_test.go | 108 ++-
go-client/idl/base/error_code.go | 34 +
go-client/idl/base/host_port.go | 104 +++
.../{rpc_address_test.go => host_port_test.go} | 31 +-
go-client/idl/base/rpc_address.go | 6 +-
idl/bulk_load.thrift | 72 +-
idl/dsn.layer2.thrift | 19 +-
idl/duplication.thrift | 20 +
idl/meta_admin.thrift | 52 +-
idl/metadata.thrift | 15 +-
idl/partition_split.thrift | 27 +-
idl/replica_admin.thrift | 5 +-
.../org/apache/pegasus/client/ClientOptions.java | 79 ++-
.../pegasus/client/retry/DefaultRetryPolicy.java | 48 ++
.../retry/ExponentialBackoffRetryPolicy.java | 66 ++
.../RetryPolicies.java} | 18 +-
.../apache/pegasus/client/retry/RetryPolicy.java | 53 +-
.../pegasus/rpc/async/ClientRequestRound.java | 4 +-
.../apache/pegasus/rpc/async/ClusterManager.java | 23 +-
.../apache/pegasus/rpc/async/ReplicaSession.java | 2 +-
.../org/apache/pegasus/rpc/async/TableHandler.java | 33 +-
.../client/retry/TestDefaultRetryPolicy.java | 49 ++
.../retry/TestExponentialBackoffRetryPolicy.java | 66 ++
run.sh | 22 +-
scripts/recompile_thrift.sh | 2 +-
src/{server => base}/meta_store.cpp | 8 +-
src/{server => base}/meta_store.h | 14 +-
src/block_service/test/main.cpp | 4 +-
src/client/partition_resolver.cpp | 10 +-
src/client/partition_resolver.h | 37 +-
src/client/partition_resolver_manager.cpp | 16 +-
src/client/partition_resolver_manager.h | 4 +-
src/client/partition_resolver_simple.cpp | 62 +-
src/client/partition_resolver_simple.h | 12 +-
src/client/replication_ddl_client.cpp | 288 ++++----
src/client/replication_ddl_client.h | 78 ++-
src/client/test/ddl_client_test.cpp | 27 +-
src/client_lib/pegasus_client_impl.cpp | 13 +-
src/client_lib/pegasus_client_impl.h | 4 +-
src/common/backup_common.cpp | 9 +-
src/common/backup_common.h | 2 +-
src/common/consensus.thrift | 60 +-
src/common/duplication_common.cpp | 9 +
src/common/duplication_common.h | 1 +
src/common/fs_manager.cpp | 10 +-
src/common/json_helper.h | 5 +-
src/common/replication_common.cpp | 73 +-
src/common/replication_common.h | 11 +-
src/common/replication_other_types.h | 53 +-
src/common/test/main.cpp | 4 +-
src/common/test/replication_common_test.cpp | 8 +-
src/failure_detector/failure_detector.cpp | 153 +++--
src/failure_detector/failure_detector.h | 48 +-
.../failure_detector_multimaster.cpp | 70 +-
.../failure_detector_multimaster.h | 28 +-
src/failure_detector/fd.thrift | 27 +-
src/failure_detector/test/failure_detector.cpp | 122 ++--
src/geo/test/geo_test.cpp | 10 +-
src/http/builtin_http_calls.cpp | 14 +-
src/http/config_http_service.cpp | 6 +
src/http/http_server.cpp | 11 +-
src/http/http_server.h | 16 +-
src/http/pprof_http_service.cpp | 10 +-
src/http/pprof_http_service.h | 17 +-
src/http/test/http_server_test.cpp | 9 +-
src/http/test/main.cpp | 4 +-
src/include/rrdb/rrdb.client.h | 2 +-
src/meta/app_balance_policy.cpp | 22 +-
src/meta/app_balance_policy.h | 6 +-
src/meta/backup_engine.cpp | 18 +-
src/meta/backup_engine.h | 5 +-
src/meta/cluster_balance_policy.cpp | 91 +--
src/meta/cluster_balance_policy.h | 50 +-
src/meta/duplication/duplication_info.cpp | 23 +-
src/meta/duplication/duplication_info.h | 44 +-
src/meta/duplication/meta_duplication_service.cpp | 272 +++++---
src/meta/duplication/meta_duplication_service.h | 10 +-
src/meta/greedy_load_balancer.cpp | 69 +-
src/meta/greedy_load_balancer.h | 14 +-
src/meta/load_balance_policy.cpp | 277 ++++----
src/meta/load_balance_policy.h | 61 +-
src/meta/meta_backup_service.cpp | 16 +-
src/meta/meta_backup_service.h | 6 +-
src/meta/meta_bulk_load_ingestion_context.cpp | 8 +-
src/meta/meta_bulk_load_ingestion_context.h | 12 +-
src/meta/meta_bulk_load_service.cpp | 129 ++--
src/meta/meta_bulk_load_service.h | 22 +-
src/meta/meta_data.cpp | 65 +-
src/meta/meta_data.h | 107 +--
src/meta/meta_http_service.cpp | 51 +-
src/meta/meta_http_service.h | 32 +-
src/meta/meta_server_failure_detector.cpp | 121 ++--
src/meta/meta_server_failure_detector.h | 26 +-
src/meta/meta_service.cpp | 54 +-
src/meta/meta_service.h | 40 +-
src/meta/meta_split_service.cpp | 4 +-
src/meta/partition_guardian.cpp | 259 ++++---
src/meta/partition_guardian.h | 8 +-
src/meta/server_load_balancer.cpp | 8 +-
src/meta/server_load_balancer.h | 10 +-
src/meta/server_state.cpp | 423 ++++++++----
src/meta/server_state.h | 21 +-
src/meta/server_state_restore.cpp | 4 +-
src/meta/test/backup_test.cpp | 11 +-
.../test/balancer_simulator/balancer_simulator.cpp | 40 +-
src/meta/test/balancer_validator.cpp | 67 +-
src/meta/test/cluster_balance_policy_test.cpp | 173 ++---
src/meta/test/copy_replica_operation_test.cpp | 126 ++--
src/meta/test/duplication_info_test.cpp | 97 +--
src/meta/test/ford_fulkerson_test.cpp | 133 ++--
src/meta/test/json_compacity.cpp | 5 +
src/meta/test/meta_app_operation_test.cpp | 4 +-
src/meta/test/meta_backup_test.cpp | 12 +-
src/meta/test/meta_bulk_load_ingestion_test.cpp | 32 +-
src/meta/test/meta_bulk_load_service_test.cpp | 74 +-
src/meta/test/meta_data.cpp | 202 +++---
src/meta/test/meta_duplication_service_test.cpp | 358 +++++-----
src/meta/test/meta_partition_guardian_test.cpp | 390 ++++++-----
src/meta/test/meta_service_test.cpp | 13 +-
src/meta/test/meta_split_service_test.cpp | 10 +-
src/meta/test/meta_test_base.cpp | 21 +-
src/meta/test/meta_test_base.h | 8 +-
src/meta/test/misc/misc.cpp | 157 +++--
src/meta/test/misc/misc.h | 33 +-
src/meta/test/state_sync_test.cpp | 43 +-
src/meta/test/update_configuration_test.cpp | 121 ++--
src/nfs/nfs.thrift | 38 +-
src/nfs/nfs_client_impl.cpp | 47 +-
src/nfs/nfs_node.cpp | 4 +-
src/nfs/nfs_node.h | 8 +-
src/nfs/test/main.cpp | 99 ++-
src/perf_counter/perf_counters.cpp | 38 +-
src/redis_protocol/proxy/config.ini | 2 -
src/redis_protocol/proxy_lib/proxy_layer.cpp | 20 +-
src/redis_protocol/proxy_lib/proxy_layer.h | 15 +-
src/redis_protocol/proxy_lib/redis_parser.cpp | 10 +-
src/redis_protocol/proxy_ut/config.ini | 2 -
src/replica/backup/test/main.cpp | 4 +-
src/replica/bulk_load/replica_bulk_loader.cpp | 131 ++--
src/replica/bulk_load/test/main.cpp | 4 +-
.../bulk_load/test/replica_bulk_loader_test.cpp | 33 +-
src/replica/disk_cleaner.cpp | 2 +-
src/replica/duplication/duplication_pipeline.cpp | 3 +-
src/replica/duplication/duplication_sync_timer.cpp | 93 +--
src/replica/duplication/duplication_sync_timer.h | 8 +-
src/replica/duplication/load_from_private_log.cpp | 4 +
src/replica/duplication/load_from_private_log.h | 4 +-
src/replica/duplication/replica_duplicator.cpp | 9 +
src/replica/duplication/replica_duplicator.h | 7 +-
.../duplication/replica_duplicator_manager.cpp | 1 +
.../duplication/replica_duplicator_manager.h | 4 +-
src/replica/duplication/replica_follower.cpp | 75 +-
src/replica/duplication/replica_follower.h | 16 +-
.../test/dup_replica_http_service_test.cpp | 3 +-
.../test/duplication_sync_timer_test.cpp | 43 +-
src/replica/duplication/test/main.cpp | 4 +-
.../duplication/test/replica_duplicator_test.cpp | 34 +-
.../duplication/test/replica_follower_test.cpp | 113 +++-
src/replica/mutation.cpp | 9 +-
src/replica/replica.cpp | 12 +-
src/replica/replica.h | 31 +-
src/replica/replica_2pc.cpp | 36 +-
src/replica/replica_check.cpp | 34 +-
src/replica/replica_chkpt.cpp | 23 +-
src/replica/replica_config.cpp | 142 ++--
src/replica/replica_context.cpp | 19 +-
src/replica/replica_context.h | 24 +-
src/replica/replica_disk_migrator.cpp | 2 +-
src/replica/replica_failover.cpp | 10 +-
src/replica/replica_http_service.cpp | 1 +
src/replica/replica_http_service.h | 12 +-
src/replica/replica_init.cpp | 8 +-
src/replica/replica_learn.cpp | 419 +++++++-----
src/replica/replica_restore.cpp | 8 +-
src/replica/replica_stub.cpp | 305 +++++----
src/replica/replica_stub.h | 36 +-
src/replica/replication_app_base.cpp | 6 +-
src/replica/replication_app_base.h | 5 +
src/replica/replication_service_app.cpp | 3 +-
src/replica/split/replica_split_manager.cpp | 89 ++-
src/replica/split/replica_split_manager.h | 10 +-
src/replica/split/test/main.cpp | 4 +-
src/replica/split/test/replica_split_test.cpp | 49 +-
.../storage/simple_kv/simple_kv.app.example.h | 4 +-
src/replica/storage/simple_kv/simple_kv.client.h | 3 +-
src/replica/storage/simple_kv/test/case-003.ini | 1 -
src/replica/storage/simple_kv/test/case-004.ini | 1 -
src/replica/storage/simple_kv/test/case-101.ini | 4 -
src/replica/storage/simple_kv/test/case-102.ini | 4 -
src/replica/storage/simple_kv/test/case-105.ini | 1 -
src/replica/storage/simple_kv/test/case-106.ini | 4 -
src/replica/storage/simple_kv/test/case-201.ini | 2 -
src/replica/storage/simple_kv/test/case-202-1.ini | 2 -
src/replica/storage/simple_kv/test/case-205.ini | 2 -
src/replica/storage/simple_kv/test/case-206.ini | 1 -
src/replica/storage/simple_kv/test/case-210.ini | 2 -
src/replica/storage/simple_kv/test/case-213.ini | 2 -
src/replica/storage/simple_kv/test/case-214.ini | 2 -
src/replica/storage/simple_kv/test/case-215.ini | 1 -
src/replica/storage/simple_kv/test/case.cpp | 12 +-
src/replica/storage/simple_kv/test/case.h | 14 +-
src/replica/storage/simple_kv/test/checker.cpp | 65 +-
src/replica/storage/simple_kv/test/checker.h | 10 +-
src/replica/storage/simple_kv/test/client.cpp | 31 +-
src/replica/storage/simple_kv/test/client.h | 11 +-
src/replica/storage/simple_kv/test/common.cpp | 10 +-
src/replica/storage/simple_kv/test/common.h | 6 +-
src/replica/test/main.cpp | 4 +-
src/replica/test/mock_utils.h | 13 +-
src/replica/test/open_replica_test.cpp | 3 +-
src/replica/test/replica_disk_migrate_test.cpp | 6 +-
src/replica/test/replica_disk_test_base.h | 4 +-
src/replica/test/replica_http_service_test.cpp | 2 +-
src/replica/test/replica_learn_test.cpp | 3 +-
src/replica/test/replica_test.cpp | 8 +-
src/runtime/api_layer1.h | 3 +
src/runtime/global_config.cpp | 201 +++---
src/runtime/global_config.h | 24 +-
src/runtime/profiler.cpp | 47 +-
src/runtime/rpc/asio_net_provider.cpp | 34 +
src/runtime/rpc/asio_net_provider.h | 10 +-
src/runtime/rpc/dns_resolver.cpp | 21 +
src/runtime/rpc/dns_resolver.h | 4 +
src/runtime/rpc/dsn_message_parser.cpp | 2 +-
src/runtime/rpc/group_address.h | 6 +-
src/runtime/rpc/group_host_port.h | 3 +-
src/runtime/rpc/network.cpp | 9 +-
src/runtime/rpc/network.h | 6 +-
src/runtime/rpc/network.sim.cpp | 3 +
src/runtime/rpc/network.sim.h | 5 +-
src/runtime/rpc/rpc_address.h | 2 +-
src/runtime/rpc/rpc_engine.cpp | 14 +-
src/runtime/rpc/rpc_engine.h | 6 +-
src/runtime/rpc/rpc_holder.h | 4 +-
src/runtime/rpc/rpc_host_port.cpp | 30 +-
src/runtime/rpc/rpc_host_port.h | 15 +
src/runtime/rpc/rpc_message.cpp | 7 +-
src/runtime/rpc/rpc_message.h | 7 +-
src/runtime/rpc/serialization.h | 3 +
src/runtime/service_api_c.cpp | 48 +-
src/runtime/service_app.h | 8 +-
src/runtime/service_engine.cpp | 104 +--
src/runtime/service_engine.h | 8 +-
src/runtime/task/task_code.cpp | 24 +-
src/runtime/task/task_engine.cpp | 143 ++--
src/runtime/task/task_engine.h | 14 +-
src/runtime/task/task_spec.h | 14 +-
src/runtime/test/dns_resolver_test.cpp | 78 +++
src/runtime/test/host_port_test.cpp | 38 +-
src/runtime/test/rpc.cpp | 21 +-
src/runtime/test/service_api_c.cpp | 6 +-
src/runtime/test/task_engine.cpp | 8 +-
src/runtime/test_utils.h | 22 +-
src/runtime/tracer.cpp | 14 +-
src/server/available_detector.cpp | 4 +-
src/server/available_detector.h | 4 +-
src/server/config.ini | 4 -
src/server/config.min.ini | 5 +-
src/server/hotspot_partition_calculator.cpp | 8 +-
src/server/info_collector.cpp | 10 +-
src/server/info_collector.h | 4 +-
src/server/main.cpp | 27 +-
src/server/pegasus_manual_compact_service.cpp | 38 +-
src/server/pegasus_mutation_duplicator.cpp | 11 +-
src/server/pegasus_server_impl.cpp | 46 +-
src/server/pegasus_server_impl.h | 5 +-
src/server/pegasus_server_impl_init.cpp | 9 +-
src/server/pegasus_write_service_impl.h | 18 +-
src/server/rocksdb_wrapper.cpp | 2 +-
src/server/test/CMakeLists.txt | 2 +-
src/server/test/config.ini | 1 -
src/server/test/main.cpp | 4 +-
src/server/test/pegasus_server_impl_test.cpp | 2 +-
src/server/test/pegasus_server_test_base.h | 3 +-
src/server/test/pegasus_server_write_test.cpp | 2 +-
src/server/test/pegasus_write_service_test.cpp | 2 +-
src/shell/command_executor.h | 6 +-
src/shell/command_helper.h | 161 ++++-
src/shell/command_utils.cpp | 14 +-
src/shell/command_utils.h | 4 +-
src/shell/commands.h | 4 +
src/shell/commands/data_operations.cpp | 14 +-
src/shell/commands/detect_hotkey.cpp | 8 +-
src/shell/commands/duplication.cpp | 115 ++--
src/shell/commands/local_partition_split.cpp | 752 +++++++++++++++++++++
src/shell/commands/node_management.cpp | 44 +-
src/shell/commands/rebalance.cpp | 56 +-
src/shell/commands/recovery.cpp | 75 +-
src/shell/commands/table_management.cpp | 48 +-
src/shell/main.cpp | 43 +-
src/test/function_test/config.ini | 5 +-
.../detect_hotspot/test_detect_hotspot.cpp | 21 +-
src/test/function_test/recovery/test_recovery.cpp | 22 +-
src/test/function_test/security/config.ini | 1 -
src/test/function_test/utils/test_util.cpp | 5 +-
src/test/function_test/utils/test_util.h | 4 +-
src/test/kill_test/config.ini | 1 -
src/test/kill_test/job.h | 4 +-
src/test/kill_test/kill_testor.cpp | 18 +-
src/test/kill_test/kill_testor.h | 4 +-
src/test/kill_test/killer_handler_shell.cpp | 11 +-
src/test/pressure_test/config-pressure.ini | 1 -
src/utils/blob.h | 1 +
src/utils/command_manager.cpp | 133 ++--
src/utils/command_manager.h | 38 +-
src/utils/config_api.cpp | 10 -
src/utils/config_api.h | 8 -
src/utils/errors.h | 27 +
src/utils/flags.cpp | 2 +-
src/utils/metrics.cpp | 9 +-
src/utils/simple_logger.cpp | 36 +-
src/utils/test/command_manager_test.cpp | 8 +-
src/utils/test/hostname_test.cpp | 62 +-
src/utils/test/time_utils_test.cpp | 30 +-
src/utils/utils.cpp | 100 ---
src/utils/utils.h | 28 +-
thirdparty/CMakeLists.txt | 26 +-
thirdparty/fix_prometheus-cpp_limits.patch | 10 -
328 files changed, 7960 insertions(+), 4790 deletions(-)
rename collector/hotspot/{algo.go => partition_detector.go} (54%)
create mode 100644 go-client/idl/base/host_port.go
copy go-client/idl/base/{rpc_address_test.go => host_port_test.go} (61%)
create mode 100644
java-client/src/main/java/org/apache/pegasus/client/retry/DefaultRetryPolicy.java
create mode 100644
java-client/src/main/java/org/apache/pegasus/client/retry/ExponentialBackoffRetryPolicy.java
copy java-client/src/main/java/org/apache/pegasus/client/{ListAppInfoType.java
=> retry/RetryPolicies.java} (68%)
copy src/shell/args.h =>
java-client/src/main/java/org/apache/pegasus/client/retry/RetryPolicy.java (53%)
create mode 100644
java-client/src/test/java/org/apache/pegasus/client/retry/TestDefaultRetryPolicy.java
create mode 100644
java-client/src/test/java/org/apache/pegasus/client/retry/TestExponentialBackoffRetryPolicy.java
rename src/{server => base}/meta_store.cpp (96%)
rename src/{server => base}/meta_store.h (92%)
create mode 100644 src/runtime/test/dns_resolver_test.cpp
create mode 100644 src/shell/commands/local_partition_split.cpp
delete mode 100644 thirdparty/fix_prometheus-cpp_limits.patch
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
