mirror of
https://gitee.com/milvus-io/milvus.git
synced 2024-12-04 12:59:23 +08:00
84e568ee32
Signed-off-by: yudong.cai <yudong.cai@zilliz.com> |
||
---|---|---|
.. | ||
allocator_test.go | ||
allocator.go | ||
cache_test.go | ||
cache.go | ||
data_node_test.go | ||
data_node.go | ||
data_sync_service_test.go | ||
data_sync_service.go | ||
errors_test.go | ||
errors.go | ||
flow_graph_dd_node_test.go | ||
flow_graph_dd_node.go | ||
flow_graph_delete_node_test.go | ||
flow_graph_delete_node.go | ||
flow_graph_dmstream_input_node_test.go | ||
flow_graph_dmstream_input_node.go | ||
flow_graph_insert_buffer_node_test.go | ||
flow_graph_insert_buffer_node.go | ||
flow_graph_message_test.go | ||
flow_graph_message.go | ||
flow_graph_node.go | ||
meta_service_test.go | ||
meta_service.go | ||
metrics_info.go | ||
mock_test.go | ||
OWNERS | ||
param_table_test.go | ||
param_table.go | ||
README.md | ||
segment_replica_test.go | ||
segment_replica.go | ||
type_def.go |
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.