milvus/internal/querynode
bigsheeper f55fe6be3c
Merge historical replica and streaming replica in QueryNode (#17217)
Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
2022-05-31 13:42:03 +08:00
..
benchmark_test.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
cgo_helper.go Cherry pick remove translateHits commit to mater (#16436) 2022-04-08 20:27:31 +08:00
collection_test.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
collection.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
data_sync_service_test.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
data_sync_service.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
errors_test.go [skip ci]Update license for qn fg deletenode (#12397) 2021-11-29 20:15:45 +08:00
errors.go [skip ci]Update license for qn fg deletenode (#12397) 2021-11-29 20:15:45 +08:00
flow_graph_delete_node_test.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
flow_graph_delete_node.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
flow_graph_filter_delete_node_test.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
flow_graph_filter_delete_node.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
flow_graph_filter_dm_node_test.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
flow_graph_filter_dm_node.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
flow_graph_insert_node_test.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
flow_graph_insert_node.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
flow_graph_message_test.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
flow_graph_message.go Reconstruct mqstream module (#15784) 2022-03-03 21:57:56 +08:00
flow_graph_node.go [skip e2e] Add comment for inputNode (#13791) 2021-12-20 19:45:06 +08:00
flow_graph_query_node_test.go Add dependency factory (#16204) 2022-04-07 22:05:32 +08:00
flow_graph_query_node.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
flow_graph_service_time_node_test.go Handle errors in DataNode and QueryNode flow graph (#17096) 2022-05-24 21:11:59 +08:00
flow_graph_service_time_node.go Handle errors in DataNode and QueryNode flow graph (#17096) 2022-05-24 21:11:59 +08:00
global_sealed_segment_manager_test.go [skip ci]Update license for qn global sealed seg (#12646) 2021-12-02 22:26:45 +08:00
global_sealed_segment_manager.go [skip e2e] Add comment for globalSealedSegmentManager (#14444) 2021-12-28 19:44:09 +08:00
impl_test.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
impl.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
load_index_info_test.go Support string type in segcore (#16546) 2022-04-29 13:35:49 +08:00
load_index_info.go Fix QueryNode log level (#16604) 2022-05-07 10:27:51 +08:00
meta_replica_test.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
meta_replica.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
metrics_info_test.go Add EtcdConfig and move PulsarConfig/RocksdbConfig/MinioConfig into BaseParamTable (#15434) 2022-02-07 10:09:45 +08:00
metrics_info.go Remove not used QueryChannel in Proxy and Query Cluster (#16856) 2022-05-30 19:50:04 +08:00
mock_test.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
OWNERS [skip ci]Update OWNERS files (#11898) 2021-11-16 15:41:11 +08:00
partition_test.go [skip ci]Update license for qn partition (#12901) 2021-12-08 09:21:56 +08:00
partition.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
plan_test.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
plan.go Add logic for search merging and a simple task scheduler for read tasks (#17022) 2022-05-23 16:41:58 +08:00
proxy_mock_test.go Support login with username and password (#15656) (#16341) 2022-04-11 19:49:34 +08:00
proxy_session_manager.go Fix QueryNode log level (#16604) 2022-05-07 10:27:51 +08:00
proxy_session.go QueryNodes send search/query results by rpc (#15223) 2022-01-17 14:41:35 +08:00
query_node_test.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
query_node.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
query_shard_service_test.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
query_shard_service.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
query_shard_test.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
query_shard.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
reduce_test.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
reduce.go Add logic for search merging and a simple task scheduler for read tasks (#17022) 2022-05-23 16:41:58 +08:00
result.go Add logic for search merging and a simple task scheduler for read tasks (#17022) 2022-05-23 16:41:58 +08:00
retrieve_test.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
retrieve.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
scheduler_policy.go Add logic for search merging and a simple task scheduler for read tasks (#17022) 2022-05-23 16:41:58 +08:00
search_test.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
search.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
segment_loader_test.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
segment_loader.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
segment_test.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
segment.go Refine segment type logs to string (#17248) 2022-05-30 15:30:01 +08:00
shard_cluster_service_test.go Fix Handoff log in shardCluster service (#17039) 2022-05-16 18:29:56 +08:00
shard_cluster_service.go Fix Handoff log in shardCluster service (#17039) 2022-05-16 18:29:56 +08:00
shard_cluster_test.go Use NodeIds instead of NodeID in segment info (#16912) 2022-05-11 17:39:53 +08:00
shard_cluster.go Add logic for search merging and a simple task scheduler for read tasks (#17022) 2022-05-23 16:41:58 +08:00
shard_node_detector_test.go Implement memory replica in Proxy, QueryNode and QueryCoord (#16470) 2022-04-20 16:15:41 +08:00
shard_node_detector.go Fix QueryNode log level (#16604) 2022-05-07 10:27:51 +08:00
shard_segment_detector_test.go Use NodeIds instead of NodeID in segment info (#16912) 2022-05-11 17:39:53 +08:00
shard_segment_detector.go Use NodeIds instead of NodeID in segment info (#16912) 2022-05-11 17:39:53 +08:00
stats_service_test.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
stats_service.go Fix QueryNode log level (#16604) 2022-05-07 10:27:51 +08:00
task_query.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
task_queue_test.go [skip ci]Update license for qn task queue (#13414) 2021-12-15 11:49:26 +08:00
task_queue.go Fix QueryNode log level (#16604) 2022-05-07 10:27:51 +08:00
task_read.go Improve query log in QueryNode (#17268) 2022-05-30 17:18:03 +08:00
task_scheduler_test.go Add logic for search merging and a simple task scheduler for read tasks (#17022) 2022-05-23 16:41:58 +08:00
task_scheduler.go Add metrics for proxy and querynode (#17205) 2022-05-27 14:12:01 +08:00
task_search.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
task_step_test.go Add metrics for proxy and querynode (#17205) 2022-05-27 14:12:01 +08:00
task_step.go Add metrics for proxy and querynode (#17205) 2022-05-27 14:12:01 +08:00
task_test.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
task.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
tsafe_replica_test.go Add logic for search merging and a simple task scheduler for read tasks (#17022) 2022-05-23 16:41:58 +08:00
tsafe_replica.go Add logic for search merging and a simple task scheduler for read tasks (#17022) 2022-05-23 16:41:58 +08:00
type_def.go Fix load failure and remove parition release related code (#16038) 2022-03-14 23:18:02 +08:00
validate_test.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00
validate.go Merge historical replica and streaming replica in QueryNode (#17217) 2022-05-31 13:42:03 +08:00