milvus

benchmark_test.go

Use go-api/v2 for milvus-proto (#24723 )

2023-06-07 21:32:37 +08:00

cgo_helper.go

Use go-api/v2 for milvus-proto (#24723 )

2023-06-07 21:32:37 +08:00

collection_test.go

Use go-api/v2 for milvus-proto (#24723 )

2023-06-07 21:32:37 +08:00

collection.go

Use go-api/v2 for milvus-proto (#24723 )

2023-06-07 21:32:37 +08:00

data_sync_service_test.go

Support the graceful stop for the query node (#21528 )

2023-01-05 20:07:36 +08:00

data_sync_service.go

fix fg metrics (#23139 )

2023-03-31 14:12:23 +08:00

distribution_test.go

Fix Dead lock in shard manager (#23445 )

2023-04-17 16:54:31 +08:00

distribution.go

refine balance mechanism by pruning code and support urgent stopping balance(#23454 ) (#23455 )

2023-04-19 17:50:31 +08:00

errors_test.go

[skip ci]Update license for qn fg deletenode (#12397 )

2021-11-29 20:15:45 +08:00

errors.go

Make querynode lazy load statslog if SkipBFLoad is true (#23904 )

2023-05-08 14:20:41 +08:00

flow_graph_delete_node_test.go

Use go-api/v2 for milvus-proto (#24723 )

2023-06-07 21:32:37 +08:00

flow_graph_delete_node.go

Limit the go routine numbers (#25171 )

2023-06-28 10:54:46 +08:00

flow_graph_filter_delete_node_test.go

Use normal msgstream instead of mqttmsgstream for delta channel (#25849 )

2023-07-24 09:09:05 +08:00

flow_graph_filter_delete_node.go

Use normal msgstream instead of mqttmsgstream for delta channel (#25849 )

2023-07-24 09:09:05 +08:00

flow_graph_filter_dm_node_test.go

Use go-api/v2 for milvus-proto (#24723 )

2023-06-07 21:32:37 +08:00

flow_graph_filter_dm_node.go

Use go-api/v2 for milvus-proto (#24723 )

2023-06-07 21:32:37 +08:00

flow_graph_insert_node_test.go

Fix deleted data is still visible (#24796 )

2023-06-13 09:14:38 +08:00

flow_graph_insert_node.go

Fix delete messages unsorted (#25757 )

2023-07-19 21:32:59 +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

Support sync all segments while close (#21576 )

2023-01-09 16:51:43 +08:00

flow_graph_query_node_test.go

Use normal msgstream instead of mqttmsgstream for delta channel (#25849 )

2023-07-24 09:09:05 +08:00

flow_graph_query_node.go

Use normal msgstream instead of mqttmsgstream for delta channel (#25849 )

2023-07-24 09:09:05 +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

Support sync all segments while close (#21576 )

2023-01-09 16:51:43 +08:00

impl_test.go

Fix the data race in waitgroup for graceful stop (#25224 )

2023-07-06 15:14:27 +08:00

impl_utils_test.go

Use go-api/v2 for milvus-proto (#24723 )

2023-06-07 21:32:37 +08:00

impl_utils.go

Use go-api/v2 for milvus-proto (#24723 )

2023-06-07 21:32:37 +08:00

impl.go

Fix the data race in waitgroup for graceful stop (#25224 )

2023-07-06 15:14:27 +08:00

load_field_data_info.go

Migrate the ability to upload and download binlog to cpp (#22382 )

2023-03-24 17:49:59 +08:00

load_index_info_test.go

Use go-api/v2 for milvus-proto (#24723 )

2023-06-07 21:32:37 +08:00

load_index_info.go

Use go-api/v2 for milvus-proto (#24723 )

2023-06-07 21:32:37 +08:00

load_segment_task_test.go

Fix deleted data is still visible (#24796 )

2023-06-13 09:14:38 +08:00

load_segment_task.go

Fix delete record may be re-applied (#24858 )

2023-07-03 15:04:25 +08:00

meta_replica_test.go

Use go-api/v2 for milvus-proto (#24723 )

2023-06-07 21:32:37 +08:00

meta_replica.go

Stop blocking until all channels & segments released (#25352 )

2023-07-19 11:44:58 +08:00

metrics_info_test.go

Use go-api/v2 for milvus-proto (#24723 )

2023-06-07 21:32:37 +08:00

metrics_info.go

Use go-api/v2 for milvus-proto (#24723 )

2023-06-07 21:32:37 +08:00

mock_test.go

Fix bug of missing JSON type when sorting retrieve results (#25412 )

2023-07-10 17:15:41 +08:00

mock_tsafe_replica_test.go

Return task context error when read task timeout (#19288 )

2022-09-28 12:08:59 +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

Log segment type as possible in QueryNode (#17846 )

2022-06-28 10:16:17 +08:00

plan_test.go

Fixbug: metric_type not set in shard member (#25266 )

2023-07-03 09:54:24 +08:00

plan.go

Fixbug: metric_type not set in shard member (#25266 )

2023-07-03 09:54:24 +08:00

query_node_test.go

Stop blocking until all channels & segments released (#25352 )

2023-07-19 11:44:58 +08:00

query_node.go

Stop blocking until all channels & segments released (#25352 )

2023-07-19 11:44:58 +08:00

query_shard_service_test.go

[2.2] Fix unsub channel alway removes queryshard (#22961 )

2023-03-23 20:25:59 +08:00

query_shard_service.go

Stop blocking until all channels & segments released (#25352 )

2023-07-19 11:44:58 +08:00

query_shard_test.go

Use go-api/v2 for milvus-proto (#24723 )

2023-06-07 21:32:37 +08:00

query_shard.go

[2.2] Fix unsub channel alway removes queryshard (#22961 )

2023-03-23 20:25:59 +08:00

rate_collector_test.go

Reduce and improve quota center log (#20058 )

2022-10-25 19:39:30 +08:00

rate_collector.go

Reduce and improve quota center log (#20058 )

2022-10-25 19:39:30 +08:00

reduce_test.go

Fixbug: metric_type not set in shard member (#25266 )

2023-07-03 09:54:24 +08:00

reduce.go

Change the type of slice_nqs and slice_topks from int32_t[] to int64_t[] (#18867 )

2022-08-29 11:36:56 +08:00

result_sorter_test.go

Fix bug of missing JSON type when sorting retrieve results (#25412 )

2023-07-10 17:15:41 +08:00

result_sorter.go

Fix bug of missing JSON type when sorting retrieve results (#25412 )

2023-07-10 17:15:41 +08:00

result_test.go

Use go-api/v2 for milvus-proto (#24723 )

2023-06-07 21:32:37 +08:00

result.go

Skip unnecessary reduce phase during search (#25166 ) (#25192 )

2023-07-03 20:14:25 +08:00

retrieve_test.go

Revert "Retrieve segments concurrently (#24358 )" (#24383 )

2023-05-25 19:45:28 +08:00

retrieve.go

Use go-api/v2 for milvus-proto (#24723 )

2023-06-07 21:32:37 +08:00

scheduler_policy_test.go

Add minCPUParallelTaskNumRatio config to allow better parallelism when estimated cpu usage of a single task is higher than total cpu usage (#25772 )

2023-07-20 10:04:50 +08:00

scheduler_policy.go

Add minCPUParallelTaskNumRatio config to allow better parallelism when estimated cpu usage of a single task is higher than total cpu usage (#25772 )

2023-07-20 10:04:50 +08:00

search_test.go

Fix segmentPtr concurrent visit and destroy (#19560 )

2022-09-29 21:54:55 +08:00

search.go

Use go-api/v2 for milvus-proto (#24723 )

2023-06-07 21:32:37 +08:00

segment_loader_test.go

Fix QueryNode always retries to load stats even file corrupted (#25029 )

2023-07-10 14:04:31 +08:00

segment_loader.go

Fix querynode always retry on corrupted statslog (#25104 )

2023-07-19 20:16:58 +08:00

segment_test.go

Add support for getting vectors by ids (#23450 ) (#25090 )

2023-07-04 17:00:27 +08:00

segment.go

Fix dup deletions make deleted records visible (#25369 )

2023-07-07 14:24:26 +08:00

shard_cluster_service_test.go

Fix watcher loop quit and channel shouldDrop logic (#23394 )

2023-04-14 07:30:30 +08:00

shard_cluster_service.go

Stop blocking until all channels & segments released (#25352 )

2023-07-19 11:44:58 +08:00

shard_cluster_test.go

Use go-api/v2 for milvus-proto (#24723 )

2023-06-07 21:32:37 +08:00

shard_cluster_version_test.go

Refactor QueryCoord (#18836 )

2022-09-15 18:48:32 +08:00

shard_cluster_version.go

Fix lastVersion not expire when there is only loadSegmentsTask (#20156 )

2022-10-28 13:05:31 +08:00

shard_cluster.go

[cherry-pick] Fix sc.distribution is nil (#25904 ) (#26010 )

2023-07-31 14:10:35 +08:00

shard_node_detector_test.go

Fix shard detector rewatch always returns closed channel (#23734 )

2023-04-26 19:26:39 +08:00

shard_node_detector.go

Fix shard detector rewatch always returns closed channel (#23734 )

2023-04-26 19:26:39 +08:00

shard_segment_detector_test.go

Fix shard detector rewatch always returns closed channel (#23734 )

2023-04-26 19:26:39 +08:00

shard_segment_detector.go

Fix shard detector rewatch always returns closed channel (#23734 )

2023-04-26 19:26:39 +08:00

snapshot_test.go

Fix concurrent segment alloc changes caused LeaderView error (#22154 )

2023-02-15 14:08:34 +08:00

snapshot.go

Fix Dead lock in shard manager (#23445 )

2023-04-17 16:54:31 +08:00

statistic_test.go

1. refine logging interfaces (#18692 )

2022-08-23 10:44:52 +08:00

statistics.go

Fix dead locks (#20121 )

2022-10-27 20:53:32 +08:00

task_query.go

Use go-api/v2 for milvus-proto (#24723 )

2023-06-07 21:32:37 +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_counter_test.go

Add quotaCenter, rateLimiter and rateCollector (#18636 )

2022-09-16 09:56:47 +08:00

task_read_counter.go

Add quotaCenter, rateLimiter and rateCollector (#18636 )

2022-09-16 09:56:47 +08:00

task_read_test.go

Add NotFoundTSafer and NoReplicaAvailable to retryable error code (#22505 )

2023-03-03 16:37:49 +08:00

task_read.go

Refine usage of TimeRecorder.Record (#23143 )

2023-03-30 21:04:23 +08:00

task_scheduler_test.go

Support configurable policy for query node, Add user level schedule policy (#23718 )

2023-05-16 10:55:22 +08:00

task_scheduler.go

Add minCPUParallelTaskNumRatio config to allow better parallelism when estimated cpu usage of a single task is higher than total cpu usage (#25772 )

2023-07-20 10:04:50 +08:00

task_search_test.go

Refine the merge algorithm (#23721 )

2023-04-27 09:52:36 +08:00

task_search.go

Use go-api/v2 for milvus-proto (#24723 )

2023-06-07 21:32:37 +08:00

task_statistics.go

Use go-api/v2 for milvus-proto (#24723 )

2023-06-07 21:32:37 +08:00

task_test.go

Prevent exclusive consumer exception in pulsar (#25376 ) (#25378 )

2023-07-13 13:28:29 +08:00

task.go

[2.2] Fix unsub channel alway removes queryshard (#22961 )

2023-03-23 20:25:59 +08:00

tsafe_replica_test.go

Support to get real row count of segment (#18115 )

2022-07-18 09:58:28 +08:00

tsafe_replica.go

Remove debug log (#25779 )

2023-07-20 14:00:59 +08:00

type_def.go

Fix load failure and remove parition release related code (#16038 )

2022-03-14 23:18:02 +08:00

validate.go

Refine search logs in querynode (#21136 )

2022-12-12 15:23:22 +08:00

watch_dm_channels_task.go

Fix deleted data may be returned by search/query (#25513 )

2023-07-13 15:24:30 +08:00