milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
milvus/internal/datacoord/session
History
wei liu 3e9e830074
enhance: Implement rewatch mechanism for etcd failure scenarios (#43829) 
issue: #43828
Implement robust rewatch mechanism to handle etcd connection failures
and node reconnection scenarios in DataCoord and QueryCoord, along with
heartbeat lag monitoring capabilities.

Changes include:
- Implement rewatchDataNodes/rewatchQueryNodes callbacks for etcd
reconnection scenarios
- Add idempotent rewatchNodes method to handle etcd session recovery
gracefully
- Add QueryCoordLastHeartbeatTimeStamp metric for monitoring node
heartbeat lag
- Clean up heartbeat metrics when nodes go down to prevent metric leaks

---------

Signed-off-by: Wei Liu <wei.liu@zilliz.com>
 		2025-08-14 10:31:44 +08:00
..
OWNERS enhance: Move datanode/indexnode manager to session pkg (#35634) 2024-08-22 16:02:56 +08:00
README.md enhance: Move datanode/indexnode manager to session pkg (#35634) 2024-08-22 16:02:56 +08:00
cluster.go fix: Fix task state is InProgress but payload is nil (#43777) 2025-08-11 14:13:42 +08:00
cluster_test.go enhance: Use QuerySlot interface for tasks (#41989) 2025-05-23 10:30:28 +08:00
common.go enhance: Pooling for data tasks (#41256) 2025-05-20 21:06:24 +08:00
datanode_manager.go fix: Update logging context and upgrade dependencies (#41318) 2025-04-23 10:52:38 +08:00
datanode_manager_test.go enhance: Use v2 package name for pkg module (#39990) 2025-02-22 23:15:58 +08:00
mock_cluster.go enhance: Pooling for data tasks (#41256) 2025-05-20 21:06:24 +08:00
mock_data_node_manager.go enhance: Pooling for data tasks (#41256) 2025-05-20 21:06:24 +08:00
mock_node_manager.go enhance: Implement rewatch mechanism for etcd failure scenarios (#43829) 2025-08-14 10:31:44 +08:00
node_manager.go enhance: Implement rewatch mechanism for etcd failure scenarios (#43829) 2025-08-14 10:31:44 +08:00
node_manager_test.go enhance: Implement rewatch mechanism for etcd failure scenarios (#43829) 2025-08-14 10:31:44 +08:00
session.go enhance: Use v2 package name for pkg module (#39990) 2025-02-22 23:15:58 +08:00

README.md

Session Package

session package contains the worker manager/nodes abstraction for datanodes and indexnodes.