This is an automated email from the ASF dual-hosted git repository.
wangdan pushed a change to branch migrate-metrics-dev
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
discard 3197ace98 feat(new_metrics): migrate metrics for replica_stub (part 3)
(#1462)
discard 3dc7ccc06 feat(collector): migrate the collector from
pegasus-kv/collector (#1461)
omit e0d192036 feat(new_metrics): migrate metrics for replica_stub (part 2)
(#1459)
omit 2e43e33fb feat(new_metrics): migrate metrics for replica_stub (part 1)
(#1455)
omit d64870d81 feat(new_metrics): migrate replica-level metrics for
pegasus_manual_compact_service (#1443)
omit 42f572290 feat(new_metrics): migrate partition-level metrics for
partition_guardian (#1440)
omit 944b47b34 feat(new_metrics): add backup-policy-level metric entity and
migrate backup-policy-level metrics for meta_backup_service (#1438)
omit 0d85cc07f feat(new_metrics): migrate server-level metrics for
meta_service (#1437)
omit a51e5e2b8 feat(new_metrics): add partition-level metric entity and
migrate partition-level metrics for greedy_load_balancer of meta (#1435)
omit 93a2fd997 feat(new_metrics): add table-level metric entity and migrate
table-level metrics for server_state of meta (#1431)
omit 5ad4360f1 feat(new_metrics): add disk-level metric entity and migrate
disk-level metrics for fs_manager (#1427)
omit ef53c56be feat(new_metrics): migrate server-level metrics for nfs
(#1421)
omit cc121aa89 feat(new_metrics): migrate built-in server-level metrics
(#1418)
omit 1bc9007ec feat(new_metrics): add server-level metric entity (#1415)
omit 856411e69 feat(new_metrics): migrate replica-level metrics for
pegasus_mutation_duplicator (#1413)
omit 3a2643ba9 feat(new_metrics): migrate replica-level metrics for
pegasus_event_listener (#1407)
omit 78c7283d8 feat(new_metrics): migrate replica-level metrics for replica
class (#1397)
omit b296ce074 feat(new_metrics): migrate replica-level metrics for
capacity_unit_calculator (#1387)
omit bd6159144 feat(new_metrics): migrate replica-level metrics for
pegasus_server_impl (part 2) (#1386)
omit 8c9559d8e feat(new_metrics): migrate replica-level metrics for
pegasus_server_impl (part 1) (#1374)
omit b3e247ed0 feat(new_metrics): migrate replica-level metrics for write
service (#1351)
omit d6bfed53c feat(new_metrics): add replica-level metric entity (#1345)
add 0dc3e4b31 doc(go-client): add deprecated marker to
TableConnector.Close() (#1448)
add b4937faa6 fix(go-client): loopForRequest not return and retry forever
(#1444)
add ce0af37c1 feat(Ranger): Use Apache Ranger for ACL when replica
master-slave learn (#1445)
add b676991a6 refactor: remove useless function 'last_flushed_decree()'
(#1456)
add 079de23e2 feat(util): add cancel() for class defer (#1458)
add 5ab400dea refactor(log): make macros LOG_AND_RETURN_NOT_* more general
(#1457)
add 7a6c28e4a fix: fix a crash bug when open an incomplete created RocksDB
instance (#1451)
add 64414e601 feat(Ranger): Use Apache Ranger for ACL when replica
performs nfs copy (#1452)
add 12c8b56e2 fix: Fault-tolerant storage engine errors for read
operations (#1447)
add b11b45d64 fix(ddl_client): sleep for a while before retry once meta
server is busy (#1453)
new db099e41a feat(new_metrics): add replica-level metric entity (#1345)
new 39c0f8f5e feat(new_metrics): migrate replica-level metrics for write
service (#1351)
new 7e30a4ccc feat(new_metrics): migrate replica-level metrics for
pegasus_server_impl (part 1) (#1374)
new 64d930590 feat(new_metrics): migrate replica-level metrics for
pegasus_server_impl (part 2) (#1386)
new a023b82c6 feat(new_metrics): migrate replica-level metrics for
capacity_unit_calculator (#1387)
new 2ee9c545a feat(new_metrics): migrate replica-level metrics for replica
class (#1397)
new 94e522e1d feat(new_metrics): migrate replica-level metrics for
pegasus_event_listener (#1407)
new 8986ffb29 feat(new_metrics): migrate replica-level metrics for
pegasus_mutation_duplicator (#1413)
new 4cfbced69 feat(new_metrics): add server-level metric entity (#1415)
new eb3a781a7 feat(new_metrics): migrate built-in server-level metrics
(#1418)
new 6ffd53e56 feat(new_metrics): migrate server-level metrics for nfs
(#1421)
new 0ae934397 feat(new_metrics): add disk-level metric entity and migrate
disk-level metrics for fs_manager (#1427)
new 280541712 feat(new_metrics): add table-level metric entity and migrate
table-level metrics for server_state of meta (#1431)
new 81afa0602 feat(new_metrics): add partition-level metric entity and
migrate partition-level metrics for greedy_load_balancer of meta (#1435)
new 53cca5623 feat(new_metrics): migrate server-level metrics for
meta_service (#1437)
new aead1b9bf feat(new_metrics): add backup-policy-level metric entity and
migrate backup-policy-level metrics for meta_backup_service (#1438)
new 0ff94b984 feat(new_metrics): migrate partition-level metrics for
partition_guardian (#1440)
new 6b8ac2058 feat(new_metrics): migrate replica-level metrics for
pegasus_manual_compact_service (#1443)
new 665d53bc5 feat(new_metrics): migrate metrics for replica_stub (part 1)
(#1455)
new e73a889ea feat(new_metrics): migrate metrics for replica_stub (part 2)
(#1459)
new e337fa881 feat(collector): migrate the collector from
pegasus-kv/collector (#1461)
new 746932310 feat(new_metrics): migrate metrics for replica_stub (part 3)
(#1462)
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 (3197ace98)
\
N -- N -- N refs/heads/migrate-metrics-dev (746932310)
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.
The 22 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/lint_and_test_cpp.yaml | 3 +
go-client/pegasus/table_connector.go | 3 +
go-client/pegasus/table_connector_test.go | 2 +-
go-client/session/session.go | 12 +-
run.sh | 1 +
src/client/CMakeLists.txt | 2 +
src/client/replication_ddl_client.cpp | 207 +++++++++++----------
src/client/replication_ddl_client.h | 110 ++++++++++-
src/{http => client}/test/CMakeLists.txt | 10 +-
src/{shell => client/test}/config.ini | 0
src/client/test/ddl_client_test.cpp | 154 +++++++++++++++
src/{perf_counter => client}/test/main.cpp | 5 +-
.../proxy_ut => client/test}/run.sh | 8 +-
src/common/storage_serverlet.h | 37 +++-
src/nfs/nfs.thrift | 2 +
src/nfs/nfs_client_impl.cpp | 2 +
src/nfs/nfs_node.cpp | 4 +
src/nfs/nfs_node.h | 18 ++
src/nfs/nfs_node_impl.cpp | 25 ++-
src/nfs/nfs_node_simple.h | 15 +-
src/nfs/nfs_server_impl.h | 4 +-
src/nfs/test/main.cpp | 6 +
src/replica/replica.cpp | 23 ++-
src/replica/replica.h | 3 +-
src/replica/replica_learn.cpp | 1 +
src/replica/replica_stub.cpp | 32 +++-
src/replica/replica_stub.h | 45 ++++-
src/replica/replication_app_base.cpp | 133 +++++++------
src/replica/replication_app_base.h | 3 +-
src/replica/storage/simple_kv/simple_kv.server.h | 6 +-
src/replica/test/mock_utils.h | 2 +-
.../ranger/ranger_resource_policy_manager.cpp | 15 +-
src/runtime/task/task_code.h | 3 +-
src/server/meta_store.cpp | 31 +--
src/server/meta_store.h | 6 +-
src/server/pegasus_read_service.h | 5 +-
src/server/pegasus_server_impl.cpp | 70 ++++---
src/server/pegasus_server_impl.h | 2 -
.../base_api_test/integration_test.cpp | 69 ++++++-
src/test/function_test/utils/global_env.cpp | 4 +-
src/test/function_test/utils/test_util.cpp | 29 ++-
src/test/function_test/utils/utils.h | 16 +-
src/test_util/test_util.cpp | 28 ++-
src/test_util/test_util.h | 17 +-
src/utils/defer.h | 10 +-
src/utils/fail_point.h | 24 ++-
src/utils/fmt_logging.h | 11 +-
47 files changed, 927 insertions(+), 291 deletions(-)
copy src/{http => client}/test/CMakeLists.txt (88%)
copy src/{shell => client/test}/config.ini (100%)
create mode 100644 src/client/test/ddl_client_test.cpp
copy src/{perf_counter => client}/test/main.cpp (89%)
copy src/{redis_protocol/proxy_ut => client/test}/run.sh (84%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
