milvus/internal/datanode
wei liu 00f6d0ec51
fix: watch channel stuck due to misuse of timer.Reset (#37433)
issue: #37166
cause the misuse of timer.Reset, which cause dispatcher failed to send
msg to virtual channel buffer, and dispatcher do splitting again and
again, which hold the dispatcher manager's lock, block watching channel
progress.

This PR fix the misuse of timer.Reset

Signed-off-by: Wei Liu <wei.liu@zilliz.com>
2024-11-07 14:34:24 +08:00
..
allocator Replace manual composed grpc call with Broker methods (#27676) 2023-10-13 09:55:34 +08:00
channel fix: watch channel stuck due to misuse of timer.Reset (#37433) 2024-11-07 14:34:24 +08:00
compaction fix: merge sort segment loss data (#37400) 2024-11-07 11:18:26 +08:00
importv2 enhance: Return deltadata for `DeleteCodec.Deserialize` (#37214) 2024-10-29 12:04:24 +08:00
iterators enhance: Return deltadata for `DeleteCodec.Deserialize` (#37214) 2024-10-29 12:04:24 +08:00
util enhance: Implement flusher in streamingNode (#34942) 2024-08-02 18:30:23 +08:00
OWNERS [skip ci]Update OWNERS files (#11898) 2021-11-16 15:41:11 +08:00
README.md [skip ci]Change uppercase of MinIO (#9539) 2021-10-09 11:22:58 +08:00
data_node.go feat: add segment,pipeline, replica and resourcegroup api for WebUI (#37344) 2024-11-07 11:52:25 +08:00
data_node_test.go feat: add tasks page into management WebUI (#37002) 2024-10-28 10:13:29 +08:00
metrics_info.go feat: add tasks page into management WebUI (#37002) 2024-10-28 10:13:29 +08:00
services.go feat: add tasks page into management WebUI (#37002) 2024-10-28 10:13:29 +08:00
services_test.go feat: add tasks page into management WebUI (#37002) 2024-10-28 10:13:29 +08:00

README.md

Data Node

DataNode is the component to write insert and delete messages into persistent blob storage, for example MinIO or S3.

Dependency

  • KV store: a kv store that persists messages into blob storage.
  • Message stream: receive messages and publish imformation
  • Root Coordinator: get the latest unique IDs.
  • Data Coordinator: get the flush information and which message stream to subscribe.