Closed discord9 closed 3 weeks ago
Attention: Patch coverage is 29.48718%
with 165 lines
in your changes missing coverage. Please review.
Project coverage is 84.75%. Comparing base (
5566dd7
) to head (2ba19a9
). Report is 3 commits behind head on main.
The recent updates introduce significant enhancements across various modules, focusing on peer lookup mechanisms, error handling, and heartbeat functionalities. Notably, a StandalonePeerLookupService
is now woven into many components to streamline peer management. Additionally, a new heartbeat functionality ensures robust communication between flownodes and the metasrv server. These changes collectively improve error handling, peer lookup consistency, and the overall robustness of the system's network communication.
Files | Change Summaries |
---|---|
src/cmd/.../standalone.rs |
Added peer_lookup_service with StandalonePeerLookupService in the StartCommand implementation. |
src/common/meta/.../drop_flow.rs |
Introduced OptionExt for improved error handling and modified Peer creation in DropFlowProcedure . |
src/common/meta/.../ddl_manager.rs |
Added StandalonePeerLookupService to the Peer import and included peer_lookup_service field. |
src/common/meta/.../peer.rs |
Imported Arc and Error , declared new types and traits like PeerLookupService and StandalonePeerLookupService . |
src/common/meta/.../test_util.rs |
Initialized peer_lookup_service with StandalonePeerLookupService in new_ddl_context_with_kv_backend . |
src/flow/.../heartbeat.rs |
Introduced HeartbeatTask struct for sending heartbeat messages to the metasrv server. |
src/meta-srv/.../lease.rs |
Modified peer lookup functions, introduced lease durations, and added MetaPeerLookupService . |
src/meta-srv/.../metasrv.rs |
Replaced lookup_alive_datanode_peer with lookup_datanode_peer and updated method parameters. |
src/meta-srv/.../procedure/utils.rs |
Imported StandalonePeerLookupService and initialized peer_lookup_service . |
tests-integration/.../standalone.rs |
Initialized peer_lookup_service with StandalonePeerLookupService in GreptimeDbStandaloneBuilder . |
In the realm of code, where bytes do dance,
A new peer service takes its chance.
Heartbeats whisper, nodes align,
Error handling now so fine.
Lookups swift, in clusters roam,
Hail to changes, our new home. 🐇✨
Thank you for using CodeRabbit. We offer it for free to the OSS community and would appreciate your support in helping us grow. If you find it useful, would you consider giving us a shout-out on your favorite social media?
I hereby agree to the terms of the GreptimeDB CLA.
Refer to a related PR or issue link (optional)
What's changed and what's your intention?
added heartbeat&peer lookup, allowing flow to register to metasrc& using flownode in procedure
add heart beat task for flownode
add lookup service for ddlcontext so procedure can look up
Peer
for a given node idusing round-robin allocator for flow create choosing flownode
Checklist
[ ] I have written the necessary rustdoc comments.
[ ] I have added the necessary unit tests and integration tests.
[ ] This PR requires documentation updates.
Summary by CodeRabbit
New Features
Improvements
Bug Fixes
Refactor
lookup_alive_datanode_peer
tolookup_datanode_peer
and addedlookup_flownode_peer
to streamline peer lookup functionalities.