9e2d1963d4
enhance: support cchannel for streaming service ( #44143 )
...
issue: #43897
- add cchannel as a special vchannel to hold some ddl and dcl.
Signed-off-by: chyezh <chyezh@outlook.com>
2025-09-02 10:05:52 +08:00
575345ae7b
fix: get streamingnodes from service discovery without channel assign ( #44033 )
...
issue: #43767
Signed-off-by: chyezh <chyezh@outlook.com>
2025-08-26 14:29:51 +08:00
d0e3a33c37
enhance: add IsRebalanceSuspended interface for wal balancer ( #44026 )
...
issue: #43968
Signed-off-by: chyezh <chyezh@outlook.com>
2025-08-24 09:19:47 +08:00
082ca62ec1
enhance: support balancer interface for streaming client to fetch streaming node information ( #43969 )
...
issue: #43968
- Add ListStreamingNode/GetWALDistribution to fetch streaming node info
- Add SuspendRebalance/ResumeRebalance to enable or stop balance
- Add FreezeNodeIDs/DefreezeNodeIDs to freeze target node
Signed-off-by: chyezh <chyezh@outlook.com>
2025-08-21 15:55:47 +08:00
4bad293655
enhance: make upgrading from 2.5.x less down time ( #42082 )
...
issue: #40532
- start timeticksync at rootcoord if the streaming service is not
available
- stop timeticksync if the streaming service is available
- open a read-only wal if some nodes in cluster is not upgrading to 2.6
- allow to open read-write wal after all nodes in cluster is upgrading
to 2.6
---------
Signed-off-by: chyezh <chyezh@outlook.com>
2025-05-29 23:02:29 +08:00
5fd47c3c89
fix: mockery too unavailable after upgrade golang version ( #41481 )
...
issue: #41291
pr: #41318
Signed-off-by: chyezh <chyezh@outlook.com>
2025-04-24 10:46:43 +08:00
c4a41cc32b
fix: add node id check to avoid double flush at most time ( #41236 )
...
issue: #41028
Signed-off-by: chyezh <chyezh@outlook.com>
2025-04-20 22:44:38 +08:00
cb7f2fa6fd
enhance: Use v2 package name for pkg module ( #39990 )
...
Related to #39095
https://go.dev/doc/modules/version-numbers
Update pkg version according to golang dep version convention
---------
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
2025-02-22 23:15:58 +08:00
6851738fd1
fix: fix `make generate-mockery` panic with go1.22 ( #36830 )
...
https://github.com/milvus-io/milvus/issues/36831
Fix `make generate-mockery` panic.
Signed-off-by: sunby <sunbingyi1992@gmail.com>
2024-10-17 12:11:31 +08:00
fda720b880
enhance: streaming service grpc utilities ( #34436 )
...
issue: #33285
- add two grpc resolver (by session and by streaming coord assignment
service)
- add one grpc balancer (by serverID and roundrobin)
- add lazy conn to avoid block by first service discovery
- add some utility function for streaming service
Signed-off-by: chyezh <chyezh@outlook.com>
2024-07-15 20:49:38 +08:00
1bc3c0b925
enhance: implement balancer at streaming coord ( #34435 )
...
issue: #33285
- add balancer implementation
- add channel count fair balance policy
- add channel assignment discover grpc service
Signed-off-by: chyezh <chyezh@outlook.com>
2024-07-11 09:58:48 +08:00
Zhen Ye
congqixia
Bingyi Sun