This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/go_modules/go-client/k8s.io/apimachinery-0.16.13
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
omit f4f61d42c build(deps): bump k8s.io/apimachinery in /go-client
add aa3998b5f feat(duplication): allow remote replica count to be
specified for duplication (#1993)
add 371a5757c feat(plog): garbage collection is allowed to be
enabled/disabled for plog (#1996)
add c4d4a7e15 feat(encryption): add a new security configuration for
encryption key (#1999)
add 10ac661d0 refactor(encryption): change the default value of
encryption_method from AES128 to AES256 (#2005)
add 0ee404ebf feat(duplication): add options to support cluster name only
used for duplication and allow any other cluster id except myself to be ignored
(#2000)
add d7087b60f feat: Support to build server binaries separately (#2009)
add a5498a92a feat: Add 2 options to limit thread count (#2011)
add d00b25136 fix: Fix build failure on ARM architecture chips (#2013)
add 84be4f93a fix(aarch64): Set the correct LD_LIBRARY_PATH for aarch64
platforms (#2016)
add caf5c50bc build(deps): bump google.golang.org/protobuf in /collector
(#1948)
add b0033c83d feat: Add some useful time and filesystem utilies (#2020)
add 9b44580c4 fix(ut): fix the dsn.meta.test using a directorty may has
not permission (#2019)
add 1196e9568 feat(logging): Support to specify log directory (#2021)
add b39e18b74 refactor(logging): Minor refactor on logging module (#2022)
add 80fcc79cc feat(logging): Fill timestamp in log file name and limit
single file size and total count (#2024)
add 3f55ed619 refactor(host_port): Unify the hostname lookup function
(#2023)
add 7edbb2dfd feat(restore): Add 'restore_path' parameter for 'restore'
command in Cpp CLI tool (#2008)
add de4253625 feat: Distinguish log file names (#2010)
add bcc5f658b fix(backup): validate backup policy name (#2029)
add 4683a78a3 fix(duplication): fix the table name while checking if the
table of the remote cluster has been created completely (#2026)
add 4a4b113a4 fix(duplication): parameters are not recognized while
parsing add_dup shell command (#2027)
add da129c6d8 fix(duplication): use get_current_dup_cluster_name() instead
of get_current_cluster_name() for duplication (#2033)
add dff177388 chore(CI): Add building debug version on CentOS 7 job and
fix some build errors (#2032)
add 7a1c461fc feat(build): Support to specify THIRDPARTY_ROOT by setting
the environment variable (#2035)
add 53dd218d5 feat(shell): add JSON format data output to some
backup_policy commands (#2030)
add dbe66a23a chore(pack): support to pack server binaries separately
(#2034)
add 6c96b5ade fix(duplication): add warning message while trying to add a
duplication that has been existing for the same table with the same remote
cluster (#2038)
add 8fd89029c fix(shell): Add PARSE_OPT_STRS marco for shell command
execute flag input mode (#2040)
add 44e83503b chore(go-client): add generation thrift files of go-client
(#1917)
add 2ab5be67a fix(go-client): update config once replica server failed and
forward to primary meta server if it was changed (#1916)
add 1fbfd47fd fix(FQDN): Fix the bug of crash caused by un-resolved IP
address (#2044)
add 6a30e9b1d chore: fix dead link http://open-falcon.org/ (#2046)
add 7e95f31cc feat(remote_command): provide the query for the progress of
decrees including both local writes and duplications (#2045)
add a774afea1 fix(duplication): reduce the delay before last mutation is
duplicated to the remote cluster (#2048)
add 596603cae feat(java-client): use thrift-maven-plugin to generate
thrift sources instead of script (#1997)
add 8877aba8b chore(run.sh): link pegasus_shell only doesnt exist (#2053)
add 48f69d1f8 fix: Fix a typo in log when [network].enable_udp is disabled
(#2055)
add 877c6bd01 fix(scripts): downgrade_node does not work with set -e
(#2056)
add efe950dba feat(backup): Add --force option for 'disable_backup_policy'
shell command (#2057)
add 7f5039456 fix(backup): Fix the stack overflow when read large sst file
(#2059)
add 57dd0e1e5 feat(remote_command): change some remote_command shell
output to JSON format (#2058)
add 3f78d2255 fix(rocksdb): fix the problem that the usage of block cache
is not set for the metric (#2060)
add d5621be1f fix(duplication): create checkpoint for the replica with 0
or 1 record (#2054)
add 60606a4a8 refactor(format): bump clang-format to 14 (#2063)
add 42bd5bb7a chore(CI): Add envs in build_debug_on_centos7 to ensure job
can be ran on centOS 7 (#2065)
add 5cfba5569 feat(FQDN): Add host_port structures for clients and bump
actions/checkout from v3 to v4 (#2062)
add a4279ecd6 chore(CI): Force CI to run on node16 (#2070)
add 115f75dae chore(CI): Force to use actions/checkout@v3 when OS maybe
CentOS 7 or Ubuntu 18.04 (#2072)
add 102e0874d fix(CI): fix java regular workflow (#2074)
add abd1794a2 refactor(FQDN): update some logs in cpp-shell CLI (#2064)
add a12856515 fix(Dockerfile): Fix the yum install failure caused by its
EOL (#2075)
add b72274f5f refactor: Simplify code on partition_configuration (#2051)
add c05e3f65c refactor(shell): Refactor on 'remote_command' command (#2052)
add 013e2e16b feat(logging): Make it possible to print logs to stderr when
using screen_logger (#2079)
add 722af2e40 feat(docker): support arm64 (#2081)
add 34ab9cbea feat(util): Introduce map utilities (#2076)
add 097068d2f feat(logging): Introduce spdlog to thirdparty (#2084)
add 581a81125 chore(CI): Reduce the target size when build on GitHub
actions (#2086)
add 5057aadab fix(util): Fix the key doesn't print when check failed
(#2090)
add af3677e3f feat(logging): Move the logger remote_command handler to
command_manager (#2087)
add ad7b18b3c refactor(string_view): Use std::string_view instead of
absl::string_view (#2091)
add 3d39af1a4 chore(CI): Introduce clang tidy linter (#2094)
add 01b875450 refactor(scripts): Separate admin and build scripts to
independent directories (#2096)
add 9efe8d6b5 fix(duplication): fix unexpected ERR_NOT_ENOUGH_MEMBER while
checking if the remote table with only one replica is ready for duplication
(#2093)
add e68c2b9b9 fix(duplication): fix the dangling pointer after `blob`
object is moved (#2088)
add 2f843db2a fix(duplication): `min_checkpoint_decree` was reset to the
invalid decree after replica server was restarted (#2097)
add a8d99fd53 feat(duplication): add a new option to configure the
duration of the delay until the next execution if there is no mutation to be
loaded (#2099)
add 5b9f46a2e fix(github): add write permission to module labeler (#2106)
add c99cfd642 feat(new_metrics): support `server_stat` command showing
some important server-level metrics (part 1) (#2085)
add d0e926010 fix(blob): allow `blob` object to be initialized with
null-pointer char array whose length must be zero (#2110)
add bc76855f6 build(deps): bump k8s.io/apimachinery in /go-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 (f4f61d42c)
\
N -- N -- N
refs/heads/dependabot/go_modules/go-client/k8s.io/apimachinery-0.16.13
(bc76855f6)
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:
.clang-format | 110 +-
.clang-tidy | 29 +
.github/actions/build_pegasus/action.yaml | 4 +-
.../rebuild_thirdparty_if_needed/action.yaml | 4 +-
.github/workflows/build-push-env-docker.yml | 19 +-
.github/workflows/labeler.yml | 2 +-
.github/workflows/lint_and_test_admin-cli.yml | 4 +-
.github/workflows/lint_and_test_collector.yml | 6 +-
.github/workflows/lint_and_test_cpp.yaml | 106 +-
.github/workflows/lint_and_test_go-client.yml | 8 +-
.github/workflows/lint_and_test_java-client.yml | 10 +-
.github/workflows/lint_and_test_pegic.yml | 4 +-
.github/workflows/lint_and_test_scala-client.yml | 10 +-
.github/workflows/module_labeler_conf.yml | 7 +-
.github/workflows/regular-build.yml | 24 +-
.github/workflows/standardization_lint.yaml | 6 +-
.github/workflows/test_nodejs-client.yml | 4 +-
.github/workflows/test_python-client.yml | 4 +-
.github/workflows/thirdparty-regular-push.yml | 22 +-
.gitignore | 5 -
.licenserc.yaml | 24 +-
CMakeLists.txt | 11 +-
LICENSE | 25 +-
{scripts => admin_tools}/config_hdfs.sh | 0
{scripts => admin_tools}/downgrade_node.sh | 4 +-
{scripts => admin_tools}/learn_stat.py | 0
{scripts => admin_tools}/migrate_node.sh | 0
{scripts => admin_tools}/minos_common.sh | 0
{scripts => admin_tools}/pegasus_add_node_list.sh | 4 +-
{scripts => admin_tools}/pegasus_bench_run.sh | 0
.../pegasus_check_arguments.sh | 2 +-
{scripts => admin_tools}/pegasus_kill_test.sh | 0
{scripts => admin_tools}/pegasus_manual_compact.sh | 0
.../pegasus_migrate_zookeeper.sh | 2 +-
{scripts => admin_tools}/pegasus_offline_node.sh | 2 +-
.../pegasus_offline_node_list.sh | 4 +-
.../pegasus_rebalance_cluster.sh | 0
{scripts => admin_tools}/pegasus_replica_thread.sh | 0
{scripts => admin_tools}/pegasus_restart_node.sh | 2 +-
{scripts => admin_tools}/pegasus_rolling_update.sh | 4 +-
.../pegasus_set_usage_scenario.sh | 0
{scripts => admin_tools}/pegasus_stat_available.sh | 0
.../pegasus_update_ingest_behind.sh | 2 +-
{scripts => admin_tools}/sendmail.sh | 0
{scripts => build_tools}/bump_version.sh | 0
{scripts => build_tools}/check_license.py | 0
build_tools/clang_tidy.py | 98 +
{scripts => build_tools}/clear_zk.sh | 0
.../collector_table_counter_gen.py | 2 +-
{scripts => build_tools}/compile_thrift.py | 8 +-
{scripts => build_tools}/download_hadoop.sh | 0
{scripts => build_tools}/download_package.sh | 0
{scripts => build_tools}/download_zk.sh | 0
{scripts => build_tools}/format_files.sh | 4 +-
{scripts => build_tools}/pack_client.sh | 8 +-
{scripts => build_tools}/pack_common.sh | 6 +-
{scripts => build_tools}/pack_server.sh | 51 +-
{scripts => build_tools}/pack_tools.sh | 47 +-
{scripts => build_tools}/recompile_thrift.sh | 1 -
{scripts => build_tools}/redis_proto_check.py | 0
{scripts => build_tools}/run-clang-format.py | 2 +-
{scripts => build_tools}/start_zk.sh | 0
{scripts => build_tools}/stop_zk.sh | 0
cmake_modules/BaseFunctions.cmake | 12 +-
collector/go.mod | 2 +-
collector/go.sum | 4 +-
docker/clang-format-3.9/Dockerfile | 28 -
docker/pegasus-build-env/centos7/Dockerfile | 20 +-
docker/thirdparties-bin/Dockerfile | 4 +-
go-client/admin/client_test.go | 2 +-
.../idl/{base => admin}/GoUnusedProtection__.go | 2 +-
go-client/idl/admin/backup-consts.go | 27 +
go-client/idl/admin/backup.go | 5299 ++++++
go-client/idl/admin/bulk_load-consts.go | 27 +
go-client/idl/admin/bulk_load.go | 4536 ++++++
go-client/idl/admin/duplication-consts.go | 27 +
go-client/idl/admin/duplication.go | 2606 +++
go-client/idl/admin/meta_admin-consts.go | 27 +
go-client/idl/admin/meta_admin.go | 16081 +++++++++++++++++++
go-client/idl/admin/metadata-consts.go | 27 +
go-client/idl/admin/metadata.go | 1373 ++
go-client/idl/admin/partition_split-consts.go | 27 +
go-client/idl/admin/partition_split.go | 3245 ++++
.../idl/{base => cmd}/GoUnusedProtection__.go | 2 +-
go-client/idl/cmd/command-consts.go | 22 +
go-client/idl/cmd/command.go | 535 +
.../idl/{base => radmin}/GoUnusedProtection__.go | 2 +-
go-client/idl/radmin/replica_admin-consts.go | 29 +
go-client/idl/radmin/replica_admin.go | 3681 +++++
.../{base => replication}/GoUnusedProtection__.go | 2 +-
go-client/idl/replication/dsn.layer2-consts.go | 25 +
go-client/idl/replication/dsn.layer2.go | 2136 +++
.../idl/{base => rrdb}/GoUnusedProtection__.go | 2 +-
go-client/idl/rrdb/meta-remote/meta-remote.go | 183 +
go-client/idl/rrdb/rrdb-consts.go | 27 +
go-client/idl/rrdb/rrdb-remote/rrdb-remote.go | 536 +
go-client/idl/rrdb/rrdb.go | 12123 ++++++++++++++
go-client/pegasus/table_connector.go | 1 +
go-client/pegasus/table_connector_test.go | 8 +-
go-client/session/meta_call.go | 70 +-
go-client/session/meta_session.go | 18 +-
go-client/session/meta_session_test.go | 18 +-
idl/backup.thrift | 7 +-
idl/duplication.thrift | 27 +-
java-client/README.md | 6 +-
java-client/pom.xml | 31 +
.../{recompile_thrift.sh => download_thrift.sh} | 17 -
nodejs-client/src/dsn/dsn_types.js | 36 +
python-client/pypegasus/base/ttypes.py | 75 +-
python-client/pypegasus/pgclient.py | 22 +-
rfcs/2020-08-27-metric-api.md | 2 +-
run.sh | 69 +-
src/CMakeLists.txt | 1 +
src/aio/test/aio.cpp | 46 +-
src/base/idl_utils.h | 9 +-
src/base/pegasus_utils.cpp | 21 -
src/base/pegasus_utils.h | 13 +-
src/base/pegasus_value_schema.h | 18 +-
src/base/test/CMakeLists.txt | 12 +-
src/base/test/value_manager_test.cpp | 4 +-
src/base/test/value_schema_test.cpp | 8 +-
src/base/value_field.h | 4 +-
src/base/value_schema_manager.cpp | 4 +-
src/base/value_schema_manager.h | 4 +-
src/base/value_schema_v0.cpp | 8 +-
src/base/value_schema_v0.h | 6 +-
src/base/value_schema_v1.cpp | 10 +-
src/base/value_schema_v1.h | 8 +-
src/base/value_schema_v2.cpp | 10 +-
src/base/value_schema_v2.h | 8 +-
src/block_service/block_service.h | 6 +-
src/block_service/block_service_manager.cpp | 18 +-
src/block_service/hdfs/hdfs_service.cpp | 5 +-
src/block_service/local/local_service.cpp | 4 +-
src/block_service/local/local_service.h | 6 +-
src/block_service/test/hdfs_service_test.cpp | 126 +-
src/client/partition_resolver.cpp | 54 +-
src/client/partition_resolver_simple.cpp | 61 +-
src/client/partition_resolver_simple.h | 4 +-
src/client/replication_ddl_client.cpp | 184 +-
src/client/replication_ddl_client.h | 30 +-
src/client_lib/client_factory.cpp | 2 +-
src/client_lib/mutation.cpp | 2 +-
src/client_lib/pegasus_client_factory_impl.h | 4 +-
src/client_lib/pegasus_client_impl.cpp | 40 +-
src/client_lib/pegasus_scanner_impl.cpp | 27 +-
src/common/common.cpp | 23 +-
src/common/common.h | 14 +-
src/common/consensus.thrift | 13 +
src/common/duplication_common.cpp | 50 +-
src/common/duplication_common.h | 13 +-
src/common/fs_manager.cpp | 17 +-
src/common/fs_manager.h | 16 +-
src/common/json_helper.h | 10 +-
src/common/replication_common.cpp | 22 +-
src/common/replication_other_types.h | 12 +-
src/common/serialization_helper/thrift_helper.h | 6 +-
src/common/test/common_test.cpp | 17 +-
src/common/test/duplication_common_test.cpp | 44 +-
src/failure_detector/failure_detector.cpp | 84 +-
src/failure_detector/failure_detector.h | 4 +-
.../failure_detector_multimaster.cpp | 10 +-
.../failure_detector_multimaster.h | 4 +-
src/failure_detector/fd.client.h | 4 +-
src/failure_detector/fd.server.h | 4 +-
src/failure_detector/test/failure_detector.cpp | 10 +-
src/failure_detector/test/run.sh | 6 +-
src/geo/bench/bench.cpp | 5 +-
src/geo/lib/geo_client.cpp | 51 +-
src/geo/test/CMakeLists.txt | 4 +
src/{geo => gutil}/CMakeLists.txt | 5 +-
src/gutil/map_traits.h | 80 +
src/gutil/map_util.h | 717 +
src/gutil/no_destructor.h | 114 +
src/{http => gutil}/test/CMakeLists.txt | 23 +-
src/{client => gutil}/test/main.cpp | 1 -
src/gutil/test/map_traits_test.cpp | 78 +
src/gutil/test/map_util_test.h | 475 +
src/gutil/test/map_util_unittest.cpp | 523 +
src/gutil/test/no_destructor_test.cpp | 184 +
.../build.properties => src/gutil/test/run.sh | 6 +-
src/http/http_call_registry.h | 8 +-
src/http/http_client.cpp | 6 +-
src/http/http_client.h | 8 +-
src/http/http_server.cpp | 10 +-
src/http/test/uri_decoder_test.cpp | 2 +-
src/http/uri_decoder.cpp | 6 +-
src/http/uri_decoder.h | 4 +-
src/include/pegasus/error.h | 2 +-
src/include/rrdb/rrdb.code.definition.h | 4 +-
src/meta/CMakeLists.txt | 1 +
src/meta/app_balance_policy.cpp | 4 +-
src/meta/app_env_validator.cpp | 34 +-
src/meta/backup_engine.cpp | 35 +-
src/meta/cluster_balance_policy.cpp | 25 +-
src/meta/distributed_lock_service_simple.cpp | 17 +-
src/meta/distributed_lock_service_simple.h | 4 +-
src/meta/duplication/duplication_info.cpp | 10 +
src/meta/duplication/duplication_info.h | 37 +-
src/meta/duplication/meta_duplication_service.cpp | 324 +-
src/meta/duplication/meta_duplication_service.h | 4 +-
src/meta/load_balance_policy.cpp | 15 +-
src/meta/meta_backup_service.cpp | 290 +-
src/meta/meta_backup_service.h | 3 +-
src/meta/meta_bulk_load_ingestion_context.cpp | 24 +-
src/meta/meta_bulk_load_ingestion_context.h | 8 +-
src/meta/meta_bulk_load_service.cpp | 183 +-
src/meta/meta_bulk_load_service.h | 20 +-
src/meta/meta_data.cpp | 38 +-
src/meta/meta_data.h | 58 +-
src/meta/meta_http_service.cpp | 65 +-
src/meta/meta_server_failure_detector.cpp | 8 +-
src/meta/meta_server_failure_detector.h | 4 +-
src/meta/meta_service.cpp | 101 +-
src/meta/meta_split_service.cpp | 63 +-
src/meta/meta_state_service.h | 4 +-
src/meta/meta_state_service_simple.cpp | 25 +-
src/meta/meta_state_service_simple.h | 4 +-
src/meta/meta_state_service_utils_impl.h | 48 +-
src/meta/meta_state_service_zookeeper.cpp | 87 +-
src/meta/meta_state_service_zookeeper.h | 4 +-
src/meta/partition_guardian.cpp | 25 +-
src/meta/server_state.cpp | 592 +-
src/meta/server_state.h | 32 +-
src/meta/server_state_restore.cpp | 4 +-
src/meta/table_metrics.cpp | 2 +-
src/meta/test/backup_test.cpp | 2 +-
.../test/balancer_simulator/balancer_simulator.cpp | 17 +-
src/meta/test/balancer_validator.cpp | 10 +-
src/meta/test/cluster_balance_policy_test.cpp | 26 +-
src/meta/test/duplication_info_test.cpp | 39 +-
src/meta/test/ford_fulkerson_test.cpp | 8 +-
src/meta/test/meta_app_operation_test.cpp | 93 +-
src/meta/test/meta_backup_test.cpp | 26 +
src/meta/test/meta_bulk_load_ingestion_test.cpp | 54 +-
src/meta/test/meta_bulk_load_service_test.cpp | 80 +-
src/meta/test/meta_data.cpp | 24 +-
src/meta/test/meta_duplication_service_test.cpp | 245 +-
src/meta/test/meta_mauanl_compaction_test.cpp | 2 +-
src/meta/test/meta_partition_guardian_test.cpp | 37 +-
src/meta/test/meta_split_service_test.cpp | 58 +-
src/meta/test/meta_state/run.sh | 6 +-
src/meta/test/meta_test_base.cpp | 6 +-
src/meta/test/meta_test_base.h | 9 +-
src/meta/test/misc/misc.cpp | 74 +-
src/meta/test/misc/misc.h | 2 +-
src/meta/test/run.sh | 6 +-
src/meta/test/state_sync_test.cpp | 30 +-
src/meta/test/update_configuration_test.cpp | 35 +-
src/nfs/nfs_client_impl.cpp | 48 +-
src/nfs/nfs_code_definition.h | 4 +-
src/nfs/nfs_node.cpp | 2 +-
src/nfs/nfs_node.h | 2 +-
src/nfs/nfs_server_impl.cpp | 26 +-
src/nfs/test/main.cpp | 97 +-
src/perf_counter/perf_counter.h | 6 +-
src/perf_counter/perf_counter_atomic.h | 2 +-
src/perf_counter/perf_counter_wrapper.h | 2 +-
src/ranger/ranger_resource_policy_manager.cpp | 35 +-
src/redis_protocol/proxy/CMakeLists.txt | 20 +-
src/redis_protocol/proxy_lib/proxy_layer.cpp | 11 +-
src/redis_protocol/proxy_lib/proxy_layer.h | 11 +-
src/redis_protocol/proxy_lib/redis_parser.cpp | 45 +-
src/redis_protocol/proxy_lib/redis_parser.h | 6 +-
src/redis_protocol/proxy_ut/CMakeLists.txt | 22 +-
src/remote_cmd/remote_command.cpp | 2 +-
src/replica/backup/cold_backup_context.cpp | 228 +-
src/replica/backup/replica_backup_manager.cpp | 40 +-
src/replica/backup/test/run.sh | 2 +-
src/replica/bulk_load/replica_bulk_loader.cpp | 99 +-
.../bulk_load/test/replica_bulk_loader_test.cpp | 16 +-
src/replica/bulk_load/test/run.sh | 2 +-
src/replica/disk_cleaner.cpp | 4 +-
src/replica/duplication/duplication_pipeline.cpp | 27 +-
src/replica/duplication/duplication_sync_timer.cpp | 13 +-
src/replica/duplication/load_from_private_log.cpp | 4 +-
src/replica/duplication/mutation_batch.cpp | 55 +-
src/replica/duplication/mutation_batch.h | 10 +-
src/replica/duplication/mutation_duplicator.h | 4 +-
src/replica/duplication/replica_duplicator.cpp | 128 +-
src/replica/duplication/replica_duplicator.h | 33 +-
.../duplication/replica_duplicator_manager.cpp | 77 +-
.../duplication/replica_duplicator_manager.h | 48 +-
src/replica/duplication/replica_follower.cpp | 63 +-
src/replica/duplication/replica_follower.h | 43 +-
.../test/dup_replica_http_service_test.cpp | 3 +-
.../test/duplication_sync_timer_test.cpp | 36 +-
.../duplication/test/duplication_test_base.h | 19 +-
.../test/load_from_private_log_test.cpp | 13 +-
.../duplication/test/mutation_batch_test.cpp | 210 +-
.../test/replica_duplicator_manager_test.cpp | 64 +-
.../duplication/test/replica_duplicator_test.cpp | 77 +-
.../duplication/test/replica_follower_test.cpp | 32 +-
src/replica/duplication/test/run.sh | 2 +-
src/replica/log_file_stream.h | 2 +-
src/replica/mutation.cpp | 4 +-
src/replica/mutation.h | 4 +-
src/replica/mutation_cache.cpp | 4 +-
src/replica/mutation_cache.h | 4 +-
src/replica/mutation_log.cpp | 196 +-
src/replica/mutation_log.h | 169 +-
src/replica/mutation_log_replay.cpp | 70 +-
src/replica/mutation_log_utils.cpp | 8 +-
src/replica/mutation_log_utils.h | 4 +-
src/replica/prepare_list.cpp | 32 +-
src/replica/replica.cpp | 12 +-
src/replica/replica.h | 86 +-
src/replica/replica_2pc.cpp | 32 +-
src/replica/replica_backup.cpp | 51 +-
src/replica/replica_base.cpp | 4 +-
src/replica/replica_base.h | 4 +-
src/replica/replica_check.cpp | 49 +-
src/replica/replica_chkpt.cpp | 257 +-
src/replica/replica_config.cpp | 159 +-
src/replica/replica_context.cpp | 31 +-
src/replica/replica_context.h | 4 +-
src/replica/replica_disk_migrator.cpp | 9 +-
src/replica/replica_failover.cpp | 8 +-
src/replica/replica_init.cpp | 30 +-
src/replica/replica_learn.cpp | 156 +-
src/replica/replica_restore.cpp | 13 +-
src/replica/replica_stub.cpp | 252 +-
src/replica/replica_stub.h | 2 +-
src/replica/replica_throttle.cpp | 28 +-
src/replica/replication_app_base.cpp | 4 +-
src/replica/replication_app_base.h | 6 +
src/replica/split/replica_split_manager.cpp | 93 +-
src/replica/split/replica_split_manager.h | 2 +-
src/replica/split/test/replica_split_test.cpp | 26 +-
src/replica/split/test/run.sh | 2 +-
src/replica/storage/simple_kv/run.sh | 6 +-
.../storage/simple_kv/simple_kv.app.example.h | 9 +-
.../storage/simple_kv/simple_kv.code.definition.h | 6 +-
src/replica/storage/simple_kv/simple_kv.server.h | 6 +-
.../storage/simple_kv/simple_kv.server.impl.cpp | 6 +-
.../storage/simple_kv/simple_kv.server.impl.h | 10 +-
src/replica/storage/simple_kv/test/case.cpp | 10 +-
src/replica/storage/simple_kv/test/case.h | 6 +-
src/replica/storage/simple_kv/test/checker.cpp | 7 +-
src/replica/storage/simple_kv/test/checker.h | 6 +-
src/replica/storage/simple_kv/test/client.cpp | 22 +-
src/replica/storage/simple_kv/test/client.h | 6 +-
src/replica/storage/simple_kv/test/common.cpp | 18 +-
src/replica/storage/simple_kv/test/common.h | 8 +-
src/replica/storage/simple_kv/test/injector.cpp | 6 +-
src/replica/storage/simple_kv/test/injector.h | 6 +-
src/replica/storage/simple_kv/test/run.sh | 4 +-
.../simple_kv/test/simple_kv.server.impl.cpp | 54 +-
.../storage/simple_kv/test/simple_kv.server.impl.h | 58 +-
src/replica/test/log_block_test.cpp | 6 +-
src/replica/test/log_file_test.cpp | 37 +-
src/replica/test/mock_utils.h | 17 +-
src/replica/test/mutation_log_test.cpp | 41 +-
src/replica/test/open_replica_test.cpp | 10 +-
src/replica/test/replica_learn_test.cpp | 5 +-
src/replica/test/replica_test.cpp | 82 +-
src/replica/test/replica_test_base.h | 16 +-
src/replica/test/replication_service_test_app.h | 2 +-
src/replica/test/throttling_controller_test.cpp | 6 +-
src/runtime/api_task.h | 2 +-
src/runtime/env.sim.h | 4 +-
src/runtime/fault_injector.cpp | 4 +-
src/runtime/fault_injector.h | 4 +-
src/runtime/global_config.h | 8 +-
src/runtime/nativerun.h | 4 +-
src/runtime/node_scoper.h | 4 +-
src/runtime/pipeline.h | 33 +-
src/runtime/profiler.cpp | 4 +-
src/runtime/providers.common.h | 2 +-
src/runtime/rpc/asio_net_provider.cpp | 2 +
src/runtime/rpc/asio_net_provider.h | 1 +
src/runtime/rpc/dns_resolver.cpp | 2 +-
src/runtime/rpc/dsn_message_parser.cpp | 2 +-
src/runtime/rpc/dsn_message_parser.h | 50 +-
src/runtime/rpc/group_host_port.h | 10 +-
src/runtime/rpc/message_parser.cpp | 2 +-
src/runtime/rpc/message_parser_manager.h | 2 +-
src/runtime/rpc/network.cpp | 7 +-
src/runtime/rpc/network.sim.cpp | 8 +-
src/runtime/rpc/raw_message_parser.cpp | 2 +-
src/runtime/rpc/raw_message_parser.h | 50 +-
src/runtime/rpc/rpc_address.cpp | 4 +-
src/runtime/rpc/rpc_address.h | 3 +-
src/runtime/rpc/rpc_engine.cpp | 11 +-
src/runtime/rpc/rpc_holder.h | 8 +-
src/runtime/rpc/rpc_host_port.cpp | 43 +-
src/runtime/rpc/rpc_host_port.h | 4 +
src/runtime/rpc/rpc_message.h | 8 +-
src/runtime/rpc/thrift_message_parser.cpp | 4 +-
src/runtime/scheduler.cpp | 4 +-
src/runtime/serverlet.h | 2 +-
src/runtime/service_api_c.cpp | 149 +-
src/runtime/simulator.h | 5 +-
src/runtime/task/async_calls.h | 2 +-
src/runtime/task/future_types.h | 2 +-
src/runtime/task/hpc_task_queue.cpp | 4 +-
src/runtime/task/hpc_task_queue.h | 4 +-
src/runtime/task/task.h | 6 +-
src/runtime/task/task_code.cpp | 4 +-
src/runtime/task/task_code.h | 6 +-
src/runtime/task/task_engine.cpp | 15 +-
src/runtime/task/task_engine.sim.cpp | 4 +-
src/runtime/task/task_engine.sim.h | 4 +-
src/runtime/task/task_queue.cpp | 2 +-
src/runtime/task/task_spec.cpp | 6 +-
src/runtime/task/task_spec.h | 11 +-
src/runtime/task/task_tracker.cpp | 2 +-
src/runtime/task/task_tracker.h | 2 +-
src/runtime/task/task_worker.cpp | 2 +-
src/runtime/task/task_worker.h | 2 +-
src/runtime/task/timer_service.h | 2 +-
src/runtime/test/async_call.cpp | 35 +-
src/runtime/test/host_port_test.cpp | 23 +-
src/runtime/test/run.sh | 6 +-
src/runtime/test/sim_lock.cpp | 2 +-
src/runtime/threadpool_code.cpp | 2 +-
src/runtime/tracer.cpp | 2 +-
src/sample/CMakeLists.txt | 7 +-
src/sample/run.sh | 22 +-
src/security/access_controller.cpp | 5 +
src/security/sasl_client_wrapper.cpp | 8 +-
src/security/sasl_server_wrapper.cpp | 8 +-
src/security/sasl_wrapper.cpp | 4 +-
src/server/CMakeLists.txt | 88 +-
src/server/available_detector.cpp | 21 +-
src/server/available_detector.h | 2 -
src/server/capacity_unit_calculator.cpp | 2 +-
src/{sample => server/collector}/CMakeLists.txt | 16 +-
src/{test/bench_test => server/collector}/main.cpp | 44 +-
src/server/compaction_filter_rule.cpp | 26 +-
src/server/compaction_filter_rule.h | 26 +-
src/server/compaction_operation.cpp | 20 +-
src/server/compaction_operation.h | 27 +-
src/server/hotkey_collector.cpp | 10 +-
src/server/hotkey_collector.h | 4 +-
src/server/hotspot_partition_calculator.cpp | 15 +-
src/server/info_collector.cpp | 36 +-
src/server/info_collector_app.cpp | 4 +-
src/server/info_collector_app.h | 4 +-
src/server/key_ttl_compaction_filter.h | 4 +-
src/server/main.cpp | 87 +-
src/{sample => server/meta_server}/CMakeLists.txt | 16 +-
.../bench_test => server/meta_server}/main.cpp | 45 +-
src/server/pegasus_event_listener.cpp | 2 +-
src/server/pegasus_manual_compact_service.cpp | 2 +-
src/server/pegasus_mutation_duplicator.cpp | 48 +-
src/server/pegasus_mutation_duplicator.h | 6 +-
src/server/pegasus_scan_context.h | 4 +-
src/server/pegasus_server_impl.cpp | 165 +-
src/server/pegasus_server_impl.h | 6 +-
src/server/pegasus_server_impl_init.cpp | 13 +-
src/server/pegasus_server_write.cpp | 2 +-
src/server/pegasus_write_service.cpp | 6 +-
src/server/pegasus_write_service.h | 10 -
src/server/pegasus_write_service_impl.h | 34 +-
.../replica_server}/CMakeLists.txt | 16 +-
src/server/replica_server/main.cpp | 56 +
src/server/rocksdb_wrapper.cpp | 28 +-
src/server/rocksdb_wrapper.h | 14 +-
src/server/server_utils.cpp | 81 +
src/{common/common.h => server/server_utils.h} | 26 +-
src/server/test/hotkey_collector_test.cpp | 4 +-
.../test/pegasus_mutation_duplicator_test.cpp | 29 +-
src/server/test/pegasus_server_impl_test.cpp | 3 +-
.../test/pegasus_write_service_impl_test.cpp | 6 +-
src/server/test/rocksdb_wrapper_test.cpp | 8 +-
src/shell/command_helper.h | 274 +-
src/shell/command_utils.cpp | 20 +-
src/shell/command_utils.h | 2 +-
src/shell/commands.h | 3 +-
src/shell/commands/bulk_load.cpp | 4 +-
src/shell/commands/cold_backup.cpp | 141 +-
src/shell/commands/data_operations.cpp | 38 +-
src/shell/commands/debugger.cpp | 10 +-
src/shell/commands/detect_hotkey.cpp | 6 +-
src/shell/commands/duplication.cpp | 146 +-
src/shell/commands/local_partition_split.cpp | 16 +-
src/shell/commands/misc.cpp | 2 +-
src/shell/commands/node_management.cpp | 421 +-
src/shell/commands/recovery.cpp | 13 +-
src/shell/commands/table_management.cpp | 75 +-
src/shell/main.cpp | 147 +-
.../function_test/backup_restore/CMakeLists.txt | 8 +-
src/test/function_test/base_api/CMakeLists.txt | 27 +-
src/test/function_test/base_api/test_basic.cpp | 3 +-
src/test/function_test/base_api/test_batch_get.cpp | 34 +-
src/test/function_test/base_api/test_scan.cpp | 20 +-
.../function_test/bulk_load/test_bulk_load.cpp | 5 +-
.../function_test/detect_hotspot/CMakeLists.txt | 8 +-
.../detect_hotspot/test_detect_hotspot.cpp | 29 +-
.../function_test/partition_split/CMakeLists.txt | 27 +-
src/test/function_test/recovery/CMakeLists.txt | 8 +-
src/test/function_test/restore/CMakeLists.txt | 8 +-
src/test/function_test/restore/test_restore.cpp | 12 +-
src/test/function_test/throttle/CMakeLists.txt | 27 +-
src/test/function_test/utils/test_util.cpp | 39 +-
src/test/function_test/utils/test_util.h | 36 +-
src/test/function_test/utils/utils.h | 10 +-
src/test/kill_test/CMakeLists.txt | 27 +-
src/test/kill_test/job.cpp | 4 +-
src/test/kill_test/job.h | 4 +-
src/test/kill_test/kill_testor.cpp | 38 +-
src/test/kill_test/kill_testor.h | 2 +-
src/test/kill_test/killer_handler.h | 4 +-
src/test/kill_test/killer_handler_shell.cpp | 4 +-
src/test/kill_test/killer_handler_shell.h | 4 +-
src/test/kill_test/partition_kill_testor.cpp | 14 +-
src/test/pressure_test/CMakeLists.txt | 18 +-
src/test_util/test_util.h | 2 +-
src/utils/TokenBucket.h | 4 +-
src/utils/binary_reader.cpp | 4 +-
src/utils/binary_reader.h | 8 +-
src/utils/binary_writer.cpp | 6 +-
src/utils/binary_writer.h | 2 +-
src/utils/blob.h | 128 +-
src/utils/builtin_metrics.cpp | 2 +-
src/utils/chrono_literals.h | 4 +-
src/utils/command_manager.cpp | 125 +-
src/utils/command_manager.h | 53 +-
src/utils/config_helper.h | 5 +-
src/utils/configuration.cpp | 2 +-
src/utils/crc.cpp | 8 +-
src/utils/crc.h | 4 +-
src/utils/customizable_id.h | 4 +-
src/utils/distributed_lock_service.h | 26 +-
src/utils/endians.h | 6 +-
src/utils/env.cpp | 4 +-
src/utils/error_code.cpp | 2 +-
src/utils/error_code.h | 5 +
src/utils/errors.h | 10 +-
src/utils/exp_delay.h | 2 +-
src/utils/factory_store.h | 4 +-
src/utils/fail_point.cpp | 10 +-
src/utils/fail_point.h | 6 +-
src/utils/fail_point_impl.h | 10 +-
src/utils/filesystem.cpp | 53 +-
src/utils/filesystem.h | 10 +
src/utils/fmt_logging.h | 24 +
src/utils/function_traits.h | 2 +-
src/utils/gpid.cpp | 2 +-
src/utils/je_ctl.cpp | 10 +-
src/utils/latency_tracer.cpp | 2 +-
src/utils/lockp.std.h | 4 +-
src/utils/logging.cpp | 12 +-
src/utils/logging_provider.h | 17 +-
src/utils/metrics.cpp | 2 +-
src/utils/metrics.h | 118 +-
src/utils/optional.h | 6 +-
src/utils/preloadable.h | 4 +-
src/utils/priority_queue.h | 4 +-
src/utils/process_utils.cpp | 6 +-
src/utils/process_utils.h | 4 +-
src/utils/safe_strerror_posix.cpp | 4 +-
src/utils/safe_strerror_posix.h | 4 +-
src/utils/simple_logger.cpp | 381 +-
src/utils/simple_logger.h | 45 +-
src/utils/singleton_store.h | 4 +-
src/utils/string_conv.h | 22 +-
src/utils/strings.cpp | 4 +-
src/utils/synchronize.h | 6 +-
src/utils/test/TokenBucketTest.cpp | 5 +-
src/utils/test/blob_test.cpp | 145 +
src/utils/test/clear.sh | 2 +-
src/utils/test/fail_point_test.cpp | 8 +-
src/utils/test/file_system_test.cpp | 37 +
src/utils/test/fmt_logging_test.cpp | 8 +-
src/utils/test/hostname_test.cpp | 42 -
src/utils/test/logger.cpp | 157 +-
src/utils/test/long_adder_test.cpp | 2 +-
src/utils/test/main.cpp | 2 +-
src/utils/test/metrics_test.cpp | 60 +-
src/utils/test/output_utils_test.cpp | 4 +-
src/utils/test/run.sh | 6 +-
src/utils/test/string_conv_test.cpp | 46 +-
src/utils/test/time_utils_test.cpp | 25 +-
src/utils/thread_access_checker.cpp | 2 +-
src/utils/thread_access_checker.h | 2 +-
src/utils/threadpool_code.h | 2 +-
src/utils/threadpool_spec.h | 2 +-
src/utils/time_utils.cpp | 15 +-
src/utils/time_utils.h | 11 +-
src/utils/uniq_timestamp_us.h | 2 +-
src/utils/utils.cpp | 80 -
src/utils/utils.h | 15 -
src/utils/work_queue.h | 2 +-
src/utils/zlock_provider.h | 2 +-
src/utils/zlocks.h | 8 +-
.../distributed_lock_service_zookeeper.cpp | 4 +-
src/zookeeper/distributed_lock_service_zookeeper.h | 4 +-
src/zookeeper/lock_struct.cpp | 15 +-
src/zookeeper/lock_struct.h | 4 +-
src/zookeeper/lock_types.h | 4 +-
src/zookeeper/test/distributed_lock_zookeeper.cpp | 37 +-
src/zookeeper/test/run.sh | 6 +-
src/zookeeper/zookeeper_error.cpp | 4 +-
src/zookeeper/zookeeper_error.h | 2 +-
src/zookeeper/zookeeper_session.cpp | 4 +-
src/zookeeper/zookeeper_session.h | 4 +-
src/zookeeper/zookeeper_session_mgr.cpp | 4 +-
thirdparty/CMakeLists.txt | 25 +-
600 files changed, 63787 insertions(+), 6010 deletions(-)
create mode 100644 .clang-tidy
rename {scripts => admin_tools}/config_hdfs.sh (100%)
rename {scripts => admin_tools}/downgrade_node.sh (98%)
rename {scripts => admin_tools}/learn_stat.py (100%)
rename {scripts => admin_tools}/migrate_node.sh (100%)
rename {scripts => admin_tools}/minos_common.sh (100%)
rename {scripts => admin_tools}/pegasus_add_node_list.sh (92%)
rename {scripts => admin_tools}/pegasus_bench_run.sh (100%)
rename {scripts => admin_tools}/pegasus_check_arguments.sh (98%)
rename {scripts => admin_tools}/pegasus_kill_test.sh (100%)
rename {scripts => admin_tools}/pegasus_manual_compact.sh (100%)
rename {scripts => admin_tools}/pegasus_migrate_zookeeper.sh (99%)
rename {scripts => admin_tools}/pegasus_offline_node.sh (99%)
rename {scripts => admin_tools}/pegasus_offline_node_list.sh (96%)
rename {scripts => admin_tools}/pegasus_rebalance_cluster.sh (100%)
rename {scripts => admin_tools}/pegasus_replica_thread.sh (100%)
rename {scripts => admin_tools}/pegasus_restart_node.sh (99%)
rename {scripts => admin_tools}/pegasus_rolling_update.sh (98%)
rename {scripts => admin_tools}/pegasus_set_usage_scenario.sh (100%)
rename {scripts => admin_tools}/pegasus_stat_available.sh (100%)
rename {scripts => admin_tools}/pegasus_update_ingest_behind.sh (99%)
rename {scripts => admin_tools}/sendmail.sh (100%)
rename {scripts => build_tools}/bump_version.sh (100%)
rename {scripts => build_tools}/check_license.py (100%)
create mode 100755 build_tools/clang_tidy.py
rename {scripts => build_tools}/clear_zk.sh (100%)
rename {scripts => build_tools}/collector_table_counter_gen.py (98%)
rename {scripts => build_tools}/compile_thrift.py (97%)
rename {scripts => build_tools}/download_hadoop.sh (100%)
rename {scripts => build_tools}/download_package.sh (100%)
rename {scripts => build_tools}/download_zk.sh (100%)
rename {scripts => build_tools}/format_files.sh (96%)
rename {scripts => build_tools}/pack_client.sh (93%)
rename {scripts => build_tools}/pack_common.sh (93%)
rename {scripts => build_tools}/pack_server.sh (78%)
rename {scripts => build_tools}/pack_tools.sh (74%)
rename {scripts => build_tools}/recompile_thrift.sh (97%)
rename {scripts => build_tools}/redis_proto_check.py (100%)
rename {scripts => build_tools}/run-clang-format.py (99%)
rename {scripts => build_tools}/start_zk.sh (100%)
rename {scripts => build_tools}/stop_zk.sh (100%)
delete mode 100644 docker/clang-format-3.9/Dockerfile
copy go-client/idl/{base => admin}/GoUnusedProtection__.go (91%)
create mode 100644 go-client/idl/admin/backup-consts.go
create mode 100644 go-client/idl/admin/backup.go
create mode 100644 go-client/idl/admin/bulk_load-consts.go
create mode 100644 go-client/idl/admin/bulk_load.go
create mode 100644 go-client/idl/admin/duplication-consts.go
create mode 100644 go-client/idl/admin/duplication.go
create mode 100644 go-client/idl/admin/meta_admin-consts.go
create mode 100644 go-client/idl/admin/meta_admin.go
create mode 100644 go-client/idl/admin/metadata-consts.go
create mode 100644 go-client/idl/admin/metadata.go
create mode 100644 go-client/idl/admin/partition_split-consts.go
create mode 100644 go-client/idl/admin/partition_split.go
copy go-client/idl/{base => cmd}/GoUnusedProtection__.go (91%)
create mode 100644 go-client/idl/cmd/command-consts.go
create mode 100644 go-client/idl/cmd/command.go
copy go-client/idl/{base => radmin}/GoUnusedProtection__.go (90%)
create mode 100644 go-client/idl/radmin/replica_admin-consts.go
create mode 100644 go-client/idl/radmin/replica_admin.go
copy go-client/idl/{base => replication}/GoUnusedProtection__.go (87%)
create mode 100644 go-client/idl/replication/dsn.layer2-consts.go
create mode 100644 go-client/idl/replication/dsn.layer2.go
copy go-client/idl/{base => rrdb}/GoUnusedProtection__.go (91%)
create mode 100755 go-client/idl/rrdb/meta-remote/meta-remote.go
create mode 100644 go-client/idl/rrdb/rrdb-consts.go
create mode 100755 go-client/idl/rrdb/rrdb-remote/rrdb-remote.go
create mode 100644 go-client/idl/rrdb/rrdb.go
rename java-client/scripts/{recompile_thrift.sh => download_thrift.sh} (73%)
copy src/{geo => gutil}/CMakeLists.txt (88%)
create mode 100644 src/gutil/map_traits.h
create mode 100644 src/gutil/map_util.h
create mode 100644 src/gutil/no_destructor.h
copy src/{http => gutil}/test/CMakeLists.txt (83%)
copy src/{client => gutil}/test/main.cpp (95%)
create mode 100644 src/gutil/test/map_traits_test.cpp
create mode 100644 src/gutil/test/map_util_test.h
create mode 100644 src/gutil/test/map_util_unittest.cpp
create mode 100644 src/gutil/test/no_destructor_test.cpp
copy scala-client/project/build.properties => src/gutil/test/run.sh (95%)
mode change 100644 => 100755
copy src/{sample => server/collector}/CMakeLists.txt (75%)
copy src/{test/bench_test => server/collector}/main.cpp (58%)
copy src/{sample => server/meta_server}/CMakeLists.txt (74%)
copy src/{test/bench_test => server/meta_server}/main.cpp (56%)
copy src/{sample => server/replica_server}/CMakeLists.txt (74%)
create mode 100644 src/server/replica_server/main.cpp
create mode 100644 src/server/server_utils.cpp
copy src/{common/common.h => server/server_utils.h} (70%)
create mode 100644 src/utils/test/blob_test.cpp
delete mode 100644 src/utils/test/hostname_test.cpp
delete mode 100644 src/utils/utils.cpp
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
