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 6c8224195 build(deps): bump libthrift from 0.11.0 to 0.14.0 in
/java-client
add adb9d145a fix(collector): fix the problem that prometheus cannot
display the indicators collected by collector (#1851)
add f61bb0f66 fix(collector): fix the parsing way of metrics returned by
the server (#1855)
add edc5b532e fix(tcmalloc): add the version number as the missing postfix
for libtcmalloc_and_profiler.so.* otherwise it would never be linked (#1858)
add 09dc9e06d fix(collector): fix the write overwrite caused by multiple
collectors sharing a global variable DataSource (#1857)
add 195195223 refactor(test): use semicolon instead of comma to separate
each option in TEST_OPTS (#1854)
add c0fcba082 feat(http_client): add http_url class to help build URLs for
http client (#1843)
add db68a2bdd refactor(collector): define prometheus registry as
non-global variable (#1861)
add 913d08cf1 refactor(test): replace deprecated INSTANTIATE_TEST_CASE_P
with INSTANTIATE_TEST_SUITE_P (#1862)
add eda2217c2 fix: drop redundant semicolons of error_s macros (#1865)
add 966c5b831 feat: configure zookeeper c client for Kerberos
authentication when KDC is configured with "rdns = false" (#1864)
add 62f5a59f1 feat(http_client): provide a convenient API http_get that
performs an http get request on the specified URL (#1866)
add 5ea60899a feat(new_metrics): build the http query string based on
metric filters (#1870)
add 1206e6a6e feat(slog): Remove slog related code (2nd) (#1871)
add 56404f1ac feat: make checkpoint_reserve_min_count &
checkpoint_reserve_time_seconds mutable (#1878)
add 10167d19e feat(dns_resolver): add metrics for dns_resolver (#1873)
add f022c81d0 feat: use getaddrinfo() instead of gethostbyname() (#1869)
add 18ddcec14 refactor(fmt): Use operator<< instead of explict to_string()
(#1874)
add c279daabd feat(new_metrics): show sst statistics by shell app_disk
based on new metrics (#1882)
add 40c00dbb0 feat(new_metrics): show server-level resource usage by shell
nodes command based on new metrics (#1884)
add 8fd6a6ec8 feat(encryption): add key manager (#1706)
add febb95874 feat(macro): add LOG_TIMING* series macros (#1879)
add 7d581a45f fix(backup): limit the backup interval to be larger than
86400 seconds (#1883)
add 41cba64aa feat(new_metrics): show replica-level resource usage by
shell nodes command based on new metrics (#1885)
add fd137bf4a feat(new_metrics): show disk-level resource usage by shell
nodes command based on new metrics (#1889)
add 4e7525b34 fix(shell): add missing librocksdb.so.8 while packing tools
and fix errors while launching shell (#1887)
add 141a37d3e feat(new_metrics): show profiler-level latencies by shell
`nodes` command (#1891)
add 597cc38f0 fix(shell): allow bench to be launched for the directory
packaged by pack_tools on production environment (#1896)
add 1d277d9f2 refactor(host_port): Make some functions as static (#1894)
add c205356bd refactor(fmt): Use operator<< instead of explict to_string()
(2nd) (#1888)
add 3a901eb52 refactor(table_envs): Unify and remove duplicate variables
(#1890)
add 546b947ec fix(scripts): drop unnecessary dependencies for
pack_tools.sh (#1901)
add 858433dd7 feat(new_metrics): show replica-level qps and capacity units
by shell `nodes` command based on new metrics (#1899)
add 07c3985ce refactor(command_manager): Simplify command_manager code
(#1875)
add a9cfa5c05 refactor(configs): Move configs defination and declearation
to global namespace (#1876)
add 9f41be714 refactor: make class 'dns_resolver' as a singleton (#1902)
add 1129607e4 fix(configs): add missing namespace in group validator of
flags (#1905)
add 039bc6212 refactor(configs): Update some default configs and remove
some useless configs (#1877)
add fe8eb989b chore(github): add contributor lengyuexuexuan to repository
collaborators list (#1910)
add 21d29604e fix(hdfs): export LIBHDFS_OPTS=-Xrs to ensure server could
exit normally (#1911)
add fab386281 feat(new_metrics): show table stats by shell `app_stat`
command based on new metrics (part 1) (#1903)
add af256941f refactor(rpc_address): Simple refactor on rpc_address (#1897)
add 4bd798ab1 feat(new_metrics): show table stats by shell `app_stat`
command based on new metrics (part 2) (#1918)
add 550da576c feat(new_metrics): show estimated number of keys by shell
`count_data` command based on new metrics (#1920)
add dea36b1d4 refactor: optimize zookeeper client init for sasl (#1914)
add 794d411bc feat(new_metrics): show table stats by shell command based
on new metrics (part 3) (#1921)
add 09d8935b1 feat(new_metrics): show table stats by shell `app_stat`
command based on new metrics (part 4) (#1922)
add 32abf0a20 build(deps): bump org.json:json from 20160810 to 20231013 in
/java-client (#1781)
add 740ce9943 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 (6c8224195)
\
N -- N -- N
refs/heads/dependabot/maven/java-client/org.apache.thrift-libthrift-0.14.0
(740ce9943)
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:
.asf.yaml | 1 +
.github/workflows/lint_and_test_cpp.yaml | 5 +-
collector/main.go | 5 +-
collector/metrics/metric_collector.go | 65 +-
collector/webui/webserver.go | 11 +-
docker/pegasus-docker-compose/config.min.ini | 1 -
java-client/pom.xml | 2 +-
run.sh | 39 +-
scripts/config_hdfs.sh | 5 +
scripts/pack_server.sh | 2 +-
scripts/pack_tools.sh | 8 +-
src/aio/test/aio.cpp | 2 +-
src/base/pegasus_const.cpp | 153 ----
src/base/pegasus_const.h | 97 ---
src/block_service/block_service_manager.cpp | 4 +-
src/block_service/hdfs/hdfs_service.cpp | 76 +-
.../test/block_service_manager_test.cpp | 2 +-
src/block_service/test/hdfs_service_test.cpp | 17 +-
src/block_service/test/local_service_test.cpp | 2 +-
src/client/replication_ddl_client.cpp | 35 +-
src/client/test/ddl_client_test.cpp | 2 +-
src/client_lib/pegasus_client_factory_impl.cpp | 11 +-
src/client_lib/pegasus_client_impl.cpp | 7 +-
src/client_lib/pegasus_scanner_impl.cpp | 8 +-
src/common/common.cpp | 5 +-
src/common/common.h | 4 +
src/common/duplication_common.cpp | 6 +-
src/common/duplication_common.h | 4 +-
src/common/fs_manager.cpp | 44 +-
src/common/fs_manager.h | 4 +-
src/common/json_helper.h | 7 +-
src/common/replica_envs.cpp | 111 +++
src/common/replica_envs.h | 9 +-
src/common/replication_common.cpp | 152 +---
src/common/replication_common.h | 2 -
src/common/serialization_helper/thrift_helper.h | 2 +-
src/common/test/common_test.cpp | 2 -
src/common/test/fs_manager_test.cpp | 2 +-
src/common/test/run.sh | 2 +-
src/failure_detector/failure_detector.cpp | 8 +-
src/failure_detector/test/failure_detector.cpp | 26 +-
src/geo/lib/geo_client.cpp | 13 +-
src/geo/test/geo_test.cpp | 8 +-
src/http/http_client.cpp | 318 ++++++--
src/http/http_client.h | 206 ++++-
src/http/http_server.cpp | 30 +-
src/http/http_server.h | 12 +-
src/http/pprof_http_service.cpp | 20 +-
src/http/test/http_client_test.cpp | 428 ++++++++++-
src/http/test/http_status_code_test.cpp | 6 +-
src/http/test/main.cpp | 3 +-
src/meta/app_balance_policy.cpp | 46 +-
src/meta/backup_engine.cpp | 26 +-
src/meta/cluster_balance_policy.cpp | 16 +-
src/meta/duplication/duplication_info.h | 13 +-
src/meta/duplication/meta_duplication_service.cpp | 20 +-
src/meta/greedy_load_balancer.cpp | 10 +-
src/meta/load_balance_policy.cpp | 17 +-
src/meta/meta_backup_service.cpp | 102 +--
src/meta/meta_bulk_load_ingestion_context.cpp | 10 +-
src/meta/meta_bulk_load_ingestion_context.h | 6 +-
src/meta/meta_bulk_load_service.cpp | 85 +--
src/meta/meta_bulk_load_service.h | 6 +-
src/meta/meta_data.cpp | 6 +-
src/meta/meta_http_service.cpp | 27 +-
src/meta/meta_options.cpp | 12 +-
src/meta/meta_server_failure_detector.cpp | 58 +-
src/meta/meta_service.cpp | 110 ++-
src/meta/meta_service.h | 2 +-
src/meta/meta_state_service_zookeeper.cpp | 4 +-
src/meta/partition_guardian.cpp | 69 +-
src/meta/partition_guardian.h | 3 +-
src/meta/server_state.cpp | 107 ++-
src/meta/test/backup_test.cpp | 10 +-
src/meta/test/balancer_validator.cpp | 13 +-
src/meta/test/duplication_info_test.cpp | 2 +-
src/meta/test/main.cpp | 4 +-
src/meta/test/meta_app_operation_test.cpp | 8 +-
src/meta/test/meta_backup_test.cpp | 6 +-
src/meta/test/meta_bulk_load_ingestion_test.cpp | 10 +-
src/meta/test/meta_bulk_load_service_test.cpp | 8 +-
src/meta/test/meta_duplication_service_test.cpp | 3 +-
src/meta/test/meta_service_test.cpp | 6 +-
src/meta/test/meta_split_service_test.cpp | 2 +-
src/meta/test/meta_state/meta_state_service.cpp | 2 +-
src/meta/test/meta_test_base.cpp | 16 +-
src/meta/test/meta_test_base.h | 2 +-
src/meta/test/misc/misc.cpp | 11 +-
src/meta/test/misc/misc.h | 5 +-
src/meta/test/run.sh | 2 +-
src/meta/test/server_state_test.cpp | 5 +-
src/meta/test/state_sync_test.cpp | 6 +-
src/meta/test/update_configuration_test.cpp | 8 +-
src/nfs/nfs_client_impl.cpp | 107 ++-
src/nfs/nfs_server_impl.cpp | 45 +-
src/nfs/test/main.cpp | 99 +--
src/perf_counter/perf_counter_atomic.cpp | 3 +-
src/perf_counter/test/perf_counter_test.cpp | 10 +-
src/ranger/ranger_resource_policy_manager.cpp | 9 +-
.../test/ranger_resource_policy_manager_test.cpp | 3 +-
src/redis_protocol/proxy/config.ini | 10 -
src/redis_protocol/proxy_lib/redis_parser.cpp | 6 +-
src/redis_protocol/proxy_ut/redis_proxy_test.cpp | 4 +-
src/replica/CMakeLists.txt | 3 +
src/replica/backup/cold_backup_context.cpp | 1 +
src/replica/backup/replica_backup_manager.cpp | 6 +-
src/replica/backup/replica_backup_server.cpp | 5 +-
.../backup/test/replica_backup_manager_test.cpp | 2 +-
src/replica/backup/test/run.sh | 2 +-
src/replica/bulk_load/replica_bulk_loader.cpp | 50 +-
.../bulk_load/test/replica_bulk_loader_test.cpp | 8 +-
src/replica/bulk_load/test/run.sh | 2 +-
src/replica/disk_cleaner.cpp | 15 +-
src/replica/disk_cleaner.h | 8 +-
src/replica/duplication/duplication_sync_timer.cpp | 4 +-
src/replica/duplication/mutation_batch.cpp | 2 +-
src/replica/duplication/replica_duplicator.h | 4 +-
src/replica/duplication/replica_follower.cpp | 15 +-
src/replica/duplication/replica_follower.h | 6 +-
.../test/dup_replica_http_service_test.cpp | 2 +-
.../test/duplication_sync_timer_test.cpp | 2 +-
.../test/load_from_private_log_test.cpp | 7 +-
.../duplication/test/mutation_batch_test.cpp | 2 +-
.../test/replica_duplicator_manager_test.cpp | 2 +-
.../duplication/test/replica_duplicator_test.cpp | 2 +-
.../duplication/test/replica_follower_test.cpp | 10 +-
src/replica/duplication/test/run.sh | 2 +-
.../duplication/test/ship_mutation_test.cpp | 2 +-
.../kms_key_provider.cpp} | 24 +-
.../kms_key_provider.h} | 38 +-
src/replica/log_file.cpp | 2 +-
src/replica/mutation.cpp | 5 +-
src/replica/mutation_log.cpp | 9 +-
src/replica/replica.cpp | 51 +-
src/replica/replica.h | 5 +-
src/replica/replica_2pc.cpp | 48 +-
src/replica/replica_backup.cpp | 15 +-
src/replica/replica_check.cpp | 27 +-
src/replica/replica_chkpt.cpp | 29 +-
src/replica/replica_config.cpp | 4 +-
src/replica/replica_context.cpp | 2 +-
src/replica/replica_disk_migrator.cpp | 8 +-
src/replica/replica_init.cpp | 16 +-
src/replica/replica_learn.cpp | 20 +-
src/replica/replica_restore.cpp | 7 +-
src/replica/replica_stub.cpp | 279 +++----
src/replica/replica_stub.h | 12 +-
src/replica/replication_app_base.cpp | 3 +-
src/replica/replication_app_base.h | 22 +-
src/replica/split/replica_split_manager.cpp | 27 +-
src/replica/split/test/replica_split_test.cpp | 8 +-
src/replica/split/test/run.sh | 2 +-
src/replica/storage/simple_kv/run.sh | 2 +-
.../storage/simple_kv/simple_kv.app.example.h | 11 +-
src/replica/storage/simple_kv/simple_kv.main.cpp | 2 +-
src/replica/storage/simple_kv/test/case-000.ini | 5 +
src/replica/storage/simple_kv/test/case-001.ini | 5 +
src/replica/storage/simple_kv/test/case-002.ini | 5 +
src/replica/storage/simple_kv/test/case-003.ini | 5 +
src/replica/storage/simple_kv/test/case-004.ini | 5 +
src/replica/storage/simple_kv/test/case-005.ini | 5 +
src/replica/storage/simple_kv/test/case-006.ini | 5 +
src/replica/storage/simple_kv/test/case-100.ini | 5 +
src/replica/storage/simple_kv/test/case-101.ini | 5 +
src/replica/storage/simple_kv/test/case-102.ini | 5 +
src/replica/storage/simple_kv/test/case-103.ini | 5 +
src/replica/storage/simple_kv/test/case-104.ini | 5 +
src/replica/storage/simple_kv/test/case-105.ini | 5 +
src/replica/storage/simple_kv/test/case-106.ini | 5 +
src/replica/storage/simple_kv/test/case-107.ini | 5 +
src/replica/storage/simple_kv/test/case-108.ini | 5 +
src/replica/storage/simple_kv/test/case-109.ini | 5 +
src/replica/storage/simple_kv/test/case-200.ini | 5 +
src/replica/storage/simple_kv/test/case-201.ini | 5 +
src/replica/storage/simple_kv/test/case-202-0.ini | 6 +-
src/replica/storage/simple_kv/test/case-202-1.ini | 6 +-
src/replica/storage/simple_kv/test/case-203-0.ini | 6 +-
src/replica/storage/simple_kv/test/case-204.ini | 7 +-
src/replica/storage/simple_kv/test/case-205.ini | 7 +-
src/replica/storage/simple_kv/test/case-206.ini | 7 +-
src/replica/storage/simple_kv/test/case-207.ini | 7 +-
src/replica/storage/simple_kv/test/case-208.ini | 7 +-
src/replica/storage/simple_kv/test/case-209.ini | 7 +-
src/replica/storage/simple_kv/test/case-210.ini | 7 +-
src/replica/storage/simple_kv/test/case-211.ini | 7 +-
src/replica/storage/simple_kv/test/case-212.act | 1 -
src/replica/storage/simple_kv/test/case-212.ini | 7 +-
src/replica/storage/simple_kv/test/case-213.act | 1 -
src/replica/storage/simple_kv/test/case-213.ini | 7 +-
src/replica/storage/simple_kv/test/case-214.ini | 7 +-
src/replica/storage/simple_kv/test/case-215.ini | 7 +-
src/replica/storage/simple_kv/test/case-216.ini | 7 +-
src/replica/storage/simple_kv/test/case-300-0.ini | 5 +
src/replica/storage/simple_kv/test/case-300-1.ini | 5 +
src/replica/storage/simple_kv/test/case-300-2.ini | 5 +
src/replica/storage/simple_kv/test/case-301.ini | 5 +
src/replica/storage/simple_kv/test/case-302.ini | 5 +
src/replica/storage/simple_kv/test/case-303.ini | 5 +
src/replica/storage/simple_kv/test/case-304.ini | 5 +
src/replica/storage/simple_kv/test/case-305.ini | 5 +
src/replica/storage/simple_kv/test/case-306.ini | 5 +
src/replica/storage/simple_kv/test/case-307.ini | 5 +
src/replica/storage/simple_kv/test/case-400.ini | 5 +
src/replica/storage/simple_kv/test/case-401.ini | 5 +
src/replica/storage/simple_kv/test/case-402.ini | 5 +
src/replica/storage/simple_kv/test/case-600.ini | 5 +
src/replica/storage/simple_kv/test/case-601.ini | 5 +
src/replica/storage/simple_kv/test/case-602.ini | 5 +
src/replica/storage/simple_kv/test/case-603.act | 2 +-
src/replica/storage/simple_kv/test/case-603.ini | 5 +
src/replica/storage/simple_kv/test/case.cpp | 31 +-
src/replica/storage/simple_kv/test/case.h | 43 +-
src/replica/storage/simple_kv/test/checker.cpp | 4 +-
src/replica/storage/simple_kv/test/common.cpp | 30 +-
src/replica/storage/simple_kv/test/common.h | 5 +-
src/replica/storage/simple_kv/test/run.sh | 6 +-
.../storage/simple_kv/test/simple_kv.main.cpp | 2 +-
src/replica/test/log_block_test.cpp | 4 +-
src/replica/test/log_file_test.cpp | 2 +-
src/replica/test/main.cpp | 2 +-
src/replica/test/mock_utils.h | 9 +-
src/replica/test/mutation_log_learn_test.cpp | 2 +-
src/replica/test/mutation_log_test.cpp | 8 +-
src/replica/test/open_replica_test.cpp | 7 +-
src/replica/test/replica_disk_migrate_test.cpp | 35 +-
src/replica/test/replica_disk_test.cpp | 5 +-
src/replica/test/replica_disk_test_base.h | 9 +-
src/replica/test/replica_http_service_test.cpp | 16 +-
src/replica/test/replica_learn_test.cpp | 2 +-
src/replica/test/replica_test.cpp | 7 +-
src/replica/test/run.sh | 2 +-
src/runtime/env.sim.cpp | 6 +-
src/runtime/fault_injector.cpp | 4 +-
src/runtime/global_config.h | 4 +-
src/runtime/nativerun.cpp | 4 +-
src/runtime/profiler.cpp | 14 +-
src/runtime/providers.common.cpp | 4 +-
src/runtime/rpc/asio_net_provider.cpp | 24 +-
src/runtime/rpc/dns_resolver.cpp | 73 +-
src/runtime/rpc/dns_resolver.h | 29 +-
src/runtime/rpc/group_address.h | 4 +-
src/runtime/rpc/group_host_port.h | 4 +-
src/runtime/rpc/network.cpp | 16 +-
src/runtime/rpc/network.sim.cpp | 17 +-
src/runtime/rpc/rpc_address.cpp | 268 ++++---
src/runtime/rpc/rpc_address.h | 84 +-
src/runtime/rpc/rpc_engine.cpp | 2 +-
src/runtime/rpc/rpc_holder.h | 2 +-
src/runtime/rpc/rpc_host_port.cpp | 90 +--
src/runtime/rpc/rpc_host_port.h | 25 +-
src/runtime/rpc/rpc_message.cpp | 7 +-
src/runtime/service_api_c.cpp | 18 +-
src/runtime/simulator.cpp | 4 +-
src/runtime/task/task_engine.cpp | 5 +-
src/runtime/task/task_spec.cpp | 7 +-
src/runtime/test/address_test.cpp | 216 +++++-
src/runtime/test/async_call.cpp | 6 +-
src/runtime/test/corrupt_message.cpp | 10 +-
src/runtime/test/host_port_test.cpp | 33 +-
src/runtime/test/lpc.cpp | 2 +-
src/runtime/test/main.cpp | 2 +-
src/runtime/test/netprovider.cpp | 15 +-
src/runtime/test/rpc.cpp | 50 +-
src/runtime/test/rpc_holder_test.cpp | 8 +-
src/runtime/test/rpc_message.cpp | 4 +-
src/runtime/test_utils.h | 10 +-
src/runtime/tracer.cpp | 8 +-
src/security/CMakeLists.txt | 7 +-
src/security/access_controller.cpp | 5 +-
src/security/client_negotiation.cpp | 2 +-
src/security/init.cpp | 5 +-
src/security/kinit_context.cpp | 17 +-
src/security/kms_client.cpp | 193 +++++
src/security/kms_client.h | 59 ++
src/security/meta_access_controller.cpp | 5 +-
src/security/negotiation.cpp | 6 +-
src/security/negotiation_manager.cpp | 10 +-
src/security/replica_access_controller.cpp | 5 +-
src/security/sasl_client_wrapper.cpp | 5 +-
src/security/sasl_init.cpp | 3 +-
src/security/sasl_server_wrapper.cpp | 5 +-
src/security/server_negotiation.cpp | 9 +-
src/security/test/CMakeLists.txt | 6 +-
src/security/test/client_negotiation_test.cpp | 3 +-
src/security/test/main.cpp | 2 +-
src/security/test/meta_access_controller_test.cpp | 6 +-
src/security/test/negotiation_manager_test.cpp | 13 +-
.../test/replica_access_controller_test.cpp | 6 +-
src/security/test/server_negotiation_test.cpp | 4 +-
src/server/available_detector.cpp | 10 +-
src/server/capacity_unit_calculator.cpp | 6 +-
src/server/config.ini | 17 +-
src/server/config.min.ini | 1 -
src/server/hotkey_collector.cpp | 6 +-
src/server/hotspot_partition_calculator.cpp | 17 +-
src/server/info_collector.cpp | 22 +-
src/server/meta_store.cpp | 15 +-
src/server/meta_store.h | 7 +
src/server/pegasus_event_listener.cpp | 8 +-
src/server/pegasus_manual_compact_service.cpp | 32 +-
src/server/pegasus_manual_compact_service.h | 6 +
src/server/pegasus_mutation_duplicator.cpp | 3 +-
src/server/pegasus_scan_context.h | 5 +-
src/server/pegasus_server_impl.cpp | 169 +++--
src/server/pegasus_server_impl.h | 12 +-
src/server/pegasus_server_impl_init.cpp | 103 +--
src/server/pegasus_server_write.cpp | 14 +-
src/server/pegasus_write_service.cpp | 15 +-
src/server/result_writer.cpp | 6 +-
src/server/rocksdb_wrapper.cpp | 10 +-
src/server/test/capacity_unit_calculator_test.cpp | 8 +-
src/server/test/config.ini | 18 -
src/server/test/hotkey_collector_test.cpp | 10 +-
src/server/test/hotspot_partition_test.cpp | 8 +-
src/server/test/manual_compact_service_test.cpp | 85 ++-
.../test/pegasus_compression_options_test.cpp | 2 +-
.../test/pegasus_mutation_duplicator_test.cpp | 2 +-
src/server/test/pegasus_server_impl_test.cpp | 27 +-
src/server/test/pegasus_server_write_test.cpp | 2 +-
.../test/pegasus_write_service_impl_test.cpp | 2 +-
src/server/test/pegasus_write_service_test.cpp | 2 +-
src/server/test/rocksdb_wrapper_test.cpp | 2 +-
src/server/test/run.sh | 2 +-
src/shell/CMakeLists.txt | 5 +-
src/shell/command_helper.h | 842 ++++++++++++++++++---
src/shell/command_utils.cpp | 3 +-
src/shell/commands/data_operations.cpp | 112 ++-
src/shell/commands/debugger.cpp | 4 +-
src/shell/commands/node_management.cpp | 355 +++++----
src/shell/commands/rebalance.cpp | 21 +-
src/shell/commands/recovery.cpp | 31 +-
src/shell/commands/table_management.cpp | 122 +--
src/shell/main.cpp | 11 +-
src/test/bench_test/benchmark.cpp | 6 +-
src/test/function_test/CMakeLists.txt | 1 +
.../backup_restore/test_backup_and_restore.cpp | 1 -
src/test/function_test/base_api/test_batch_get.cpp | 1 -
src/test/function_test/base_api/test_scan.cpp | 8 +-
src/test/function_test/base_api/test_ttl.cpp | 15 +-
.../function_test/bulk_load/test_bulk_load.cpp | 6 +-
src/test/function_test/recovery/test_recovery.cpp | 8 +-
src/test/function_test/restore/test_restore.cpp | 9 +-
src/test/function_test/run.sh | 2 +-
.../function_test/security}/CMakeLists.txt | 29 +-
.../function_test/security}/config.ini | 23 +-
.../test => test/function_test/security}/main.cpp | 0
.../function_test/security/test_kms_client.cpp | 56 ++
src/test/function_test/throttle/test_throttle.cpp | 14 +-
src/test/function_test/utils/global_env.cpp | 15 +-
src/test/function_test/utils/global_env.h | 3 +-
src/test/function_test/utils/test_util.cpp | 4 +-
src/test/kill_test/data_verifier.cpp | 32 +-
src/test/kill_test/kill_testor.cpp | 15 +-
src/test/kill_test/killer_handler_shell.cpp | 6 +-
src/test/kill_test/partition_kill_testor.cpp | 4 +-
src/test/kill_test/process_kill_testor.cpp | 6 +-
src/test/pressure_test/config-pressure.ini | 2 +-
src/test/pressure_test/main.cpp | 16 +-
src/test_util/test_util.h | 4 +-
src/tools/mutation_log_tool.cpp | 4 +-
src/utils/CMakeLists.txt | 5 +-
src/utils/blob.h | 8 +
src/utils/builtin_metrics.cpp | 4 +-
src/utils/command_manager.cpp | 63 +-
src/utils/command_manager.h | 99 ++-
src/utils/enum_helper.h | 3 +-
src/utils/env.cpp | 11 +-
src/utils/errors.h | 12 +-
src/utils/fmt_logging.h | 8 +
src/utils/latency_tracer.cpp | 7 +-
src/utils/latency_tracer.h | 5 +-
src/utils/logging.cpp | 10 +-
src/utils/math.cpp | 1 -
src/utils/math.h | 17 +
src/utils/metrics.cpp | 65 +-
src/utils/metrics.h | 131 +++-
src/utils/shared_io_service.cpp | 8 +-
src/utils/simple_logger.cpp | 17 +-
src/utils/string_conv.h | 25 +
src/utils/strings.cpp | 11 +
src/utils/strings.h | 4 +
src/utils/test/TokenBucketTest.cpp | 2 +-
src/utils/test/enum_helper_test.cpp | 36 +-
src/utils/test/env.cpp | 2 +-
src/utils/test/file_utils.cpp | 2 +-
src/utils/test/flag_test.cpp | 6 +-
src/utils/test/hostname_test.cpp | 31 +-
src/utils/test/json_helper_test.cpp | 2 +-
src/utils/test/load_dump_object_test.cpp | 6 +-
src/utils/test/lock.std.cpp | 2 +-
src/utils/test/logger.cpp | 4 +-
src/utils/test/logging.cpp | 30 +-
src/utils/test/metrics_test.cpp | 108 ++-
src/utils/test/utils.cpp | 50 +-
src/utils/threadpool_spec.h | 12 +-
src/utils/timer.h | 165 ++++
src/utils/utils.cpp | 4 +-
.../distributed_lock_service_zookeeper.cpp | 4 +-
src/zookeeper/zookeeper_session.cpp | 127 +++-
src/zookeeper/zookeeper_session_mgr.cpp | 4 +-
400 files changed, 6298 insertions(+), 3258 deletions(-)
delete mode 100644 src/base/pegasus_const.cpp
delete mode 100644 src/base/pegasus_const.h
create mode 100644 src/common/replica_envs.cpp
copy src/{security/sasl_server_wrapper.h => replica/kms_key_provider.cpp} (69%)
copy src/{security/meta_access_controller.h => replica/kms_key_provider.h}
(53%)
create mode 100644 src/security/kms_client.cpp
create mode 100644 src/security/kms_client.h
copy src/{replica/backup/test => test/function_test/security}/CMakeLists.txt
(81%)
copy src/{security/test => test/function_test/security}/config.ini (68%)
copy src/{geo/test => test/function_test/security}/main.cpp (100%)
create mode 100644 src/test/function_test/security/test_kms_client.cpp
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
