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/rootcoord
History
Zhen Ye 6f1febe881
enhance: move streaming coord from datacoord to rootcoord (#39009) 
issue: #38399
pr: #39007

We want to support broadcast operation for both streaming and msgstream.
But msgstream can be only sent message from rootcoord and proxy.
So this pr move the streamingcoord to rootcoord to make easier
implementation.

---------

Signed-off-by: chyezh <chyezh@outlook.com>
 		2025-01-07 17:56:56 +08:00
..
mocks fix: [2.5] expand privilege group when list policy in rootcoord (#38760) 2024-12-26 15:34:49 +08:00
OWNERS [skip ci]Update OWNERS files (#11898) 2021-11-16 15:41:11 +08:00
alter_alias_task.go fix: Add version to the proxy cache to resolve concurrency issues (#38067) 2024-12-04 18:06:39 +08:00
alter_alias_task_test.go fix: Add version to the proxy cache to resolve concurrency issues (#38067) 2024-12-04 18:06:39 +08:00
alter_collection_task.go feat: support to replicate collection when the services contains the system tt msg (#37559) 2024-12-17 09:08:46 +08:00
alter_collection_task_test.go feat: support to replicate collection when the services contains the system tt msg (#37559) 2024-12-17 09:08:46 +08:00
alter_database_task.go feat: support to replicate collection when the services contains the system tt msg (#37559) 2024-12-17 09:08:46 +08:00
alter_database_task_test.go feat: support to replicate collection when the services contains the system tt msg (#37559) 2024-12-17 09:08:46 +08:00
broker.go feat: support to replicate collection when the services contains the system tt msg (#37559) 2024-12-17 09:08:46 +08:00
broker_test.go enhance: support setting properties in create database request (#34510) 2024-07-09 18:16:18 +08:00
constrant.go fix: Fix checkGeneralCapacity slowly (#37976) 2024-12-01 18:28:38 +08:00
constrant_test.go fix: Fix inaccurate general count (#38524) 2024-12-17 23:24:45 +08:00
create_alias_task.go enhance: improve rootcoord task scheduling policy (#37352) 2024-11-06 14:48:26 +08:00
create_alias_task_test.go enhance: Break down the granularity of collection info cache expired (#29977) 2024-01-30 16:45:02 +08:00
create_collection_task.go feat: support to replicate collection when the services contains the system tt msg (#37559) 2024-12-17 09:08:46 +08:00
create_collection_task_test.go feat: support to replicate collection when the services contains the system tt msg (#37559) 2024-12-17 09:08:46 +08:00
create_db_task.go enhance: the actual number of databases should equal the config value (#38006) 2024-11-29 14:44:36 +08:00
create_db_task_test.go enhance: the actual number of databases should equal the config value (#38006) 2024-11-29 14:44:36 +08:00
create_partition_task.go enhance: refine exists log print with ctx (#38080) 2024-12-14 22:36:44 +08:00
create_partition_task_test.go fix: Fix checkGeneralCapacity slowly (#37976) 2024-12-01 18:28:38 +08:00
ddl_ts_lock_manager.go Move some modules from internal to public package (#22572) 2023-04-06 19:14:32 +08:00
ddl_ts_lock_manager_test.go Format the code (#27275) 2023-09-21 09:45:27 +08:00
describe_collection_task.go fix: Add version to the proxy cache to resolve concurrency issues (#38067) 2024-12-04 18:06:39 +08:00
describe_collection_task_test.go enhance: refine rootcoord/metatable interfaces to ensure that each method includes a ctx parameter (#37846) 2024-11-21 19:30:32 +08:00
describe_db_task.go enhance: improve rootcoord task scheduling policy (#37352) 2024-11-06 14:48:26 +08:00
describe_db_task_test.go enhance: support to config the default db properties (#38035) 2024-11-27 10:04:34 +08:00
dml_channels.go enhance: refine exists log print with ctx (#38080) 2024-12-14 22:36:44 +08:00
dml_channels_test.go enhance: refine pular related mq interfaces (#38007) 2024-12-04 20:50:39 +08:00
drop_alias_task.go fix: Add version to the proxy cache to resolve concurrency issues (#38067) 2024-12-04 18:06:39 +08:00
drop_alias_task_test.go fix: Add version to the proxy cache to resolve concurrency issues (#38067) 2024-12-04 18:06:39 +08:00
drop_collection_task.go enhance: refine exists log print with ctx (#38080) 2024-12-14 22:36:44 +08:00
drop_collection_task_test.go enhance: refine rootcoord/metatable interfaces to ensure that each method includes a ctx parameter (#37846) 2024-11-21 19:30:32 +08:00
drop_db_task.go enhance: improve rootcoord task scheduling policy (#37352) 2024-11-06 14:48:26 +08:00
drop_db_task_test.go enhance: support to invalid the database meta cache (#32078) 2024-04-10 06:45:18 +08:00
drop_partition_task.go enhance: refine exists log print with ctx (#38080) 2024-12-14 22:36:44 +08:00
drop_partition_task_test.go enhance: Append drop partition msg to wal (#35326) 2024-08-07 17:28:16 +08:00
expire_cache.go enhance: Break down the granularity of collection info cache expired (#29977) 2024-01-30 16:45:02 +08:00
expire_cache_test.go enhance: Break down the granularity of collection info cache expired (#29977) 2024-01-30 16:45:02 +08:00
field_id.go feat: Support create collection with functions (#35973) 2024-09-12 10:43:06 +08:00
garbage_collector.go enhance: using streaming service in insert/upsert/flush/delete/querynode (#35406) 2024-08-29 10:03:08 +08:00
garbage_collector_test.go enhance: using streaming service in insert/upsert/flush/delete/querynode (#35406) 2024-08-29 10:03:08 +08:00
has_collection_task.go enhance: improve rootcoord task scheduling policy (#37352) 2024-11-06 14:48:26 +08:00
has_collection_task_test.go Add more metrics (#25081) 2023-06-26 17:52:44 +08:00
has_partition_task.go fix: Use the ID to retrieve the real name when collectionName is empty (#37859) 2024-11-21 14:28:32 +08:00
has_partition_task_test.go Refine state check (#27541) 2023-10-11 21:01:35 +08:00
list_db_task.go enhance: refine exists log print with ctx (#38080) 2024-12-14 22:36:44 +08:00
list_db_task_test.go enhance: support to config the default db properties (#38035) 2024-11-27 10:04:34 +08:00
meta_table.go fix: [2.5] expand privilege group when list policy in rootcoord (#38760) 2024-12-26 15:34:49 +08:00
meta_table_test.go enhance: refine exists log print with ctx (#38080) 2024-12-14 22:36:44 +08:00
metrics_info.go enhance: add disk stats within system metrics (#38033) 2024-12-06 16:32:41 +08:00
mock_test.go fix: [2.5] expand privilege group when list policy in rootcoord (#38760) 2024-12-26 15:34:49 +08:00
name_db.go feat: Implement DescribeAlias and ListAliases interfaces (#29641) 2024-01-11 19:12:51 +08:00
quota_center.go enhance: alterdatabase support delete property (#38380) 2024-12-12 17:04:43 +08:00
quota_center_test.go enhance: Use internal json(sonic) to replace std json lib (#37708) 2024-11-18 10:46:31 +08:00
redo.go Format the code (#27275) 2023-09-21 09:45:27 +08:00
redo_test.go Format the code (#27275) 2023-09-21 09:45:27 +08:00
rename_collection_task.go fix: Add version to the proxy cache to resolve concurrency issues (#38067) 2024-12-04 18:06:39 +08:00
rename_collection_task_test.go fix: Add version to the proxy cache to resolve concurrency issues (#38067) 2024-12-04 18:06:39 +08:00
root_coord.go enhance: move streaming coord from datacoord to rootcoord (#39009) 2025-01-07 17:56:56 +08:00
root_coord_test.go fix: [2.5] expand privilege group when list policy in rootcoord (#38760) 2024-12-26 15:34:49 +08:00
scheduler.go enhance: improve rootcoord task scheduling policy (#37352) 2024-11-06 14:48:26 +08:00
scheduler_test.go enhance: improve rootcoord task scheduling policy (#37352) 2024-11-06 14:48:26 +08:00
show_collection_task.go fix: [2.5] fix privilege group list and list collections (#38738) 2024-12-25 18:06:50 +08:00
show_collection_task_test.go fix: [2.5] fix privilege group list and list collections (#38738) 2024-12-25 18:06:50 +08:00
show_partition_task.go fix: Use the ID to retrieve the real name when collectionName is empty (#37859) 2024-11-21 14:28:32 +08:00
show_partition_task_test.go Refine state check (#27541) 2023-10-11 21:01:35 +08:00
step.go enhance: refine exists log print with ctx (#38080) 2024-12-14 22:36:44 +08:00
step_executor.go enhance: refine exists log print with ctx (#38080) 2024-12-14 22:36:44 +08:00
step_executor_test.go Format the code (#27275) 2023-09-21 09:45:27 +08:00
step_test.go enhance: using streaming service in insert/upsert/flush/delete/querynode (#35406) 2024-08-29 10:03:08 +08:00
task.go feat: support to replicate collection when the services contains the system tt msg (#37559) 2024-12-17 09:08:46 +08:00
task_test.go feat: support to replicate collection when the services contains the system tt msg (#37559) 2024-12-17 09:08:46 +08:00
timestamp_bench_test.go Format the code (#27275) 2023-09-21 09:45:27 +08:00
timeticksync.go enhance: refine exists log print with ctx (#38080) 2024-12-14 22:36:44 +08:00
timeticksync_test.go Optimize the codec code of session (#27360) 2023-10-01 10:33:30 +08:00
undo.go enhance: refine exists log print with ctx (#38080) 2024-12-14 22:36:44 +08:00
undo_test.go Add license to rootcoord module (#22301) 2023-02-22 11:37:45 +08:00
util.go fix: revert optimize CPU usage for CheckHealth requests (#35589) (#38555) 2024-12-19 00:38:45 +08:00
util_test.go feat: support rate limiter based on db and partition levels (#31070) 2024-04-12 16:01:19 +08:00