milvus/pkg
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
..
common enhance: Bump milvus version to v2.5.2 (#38880) 2024-12-31 15:15:59 +08:00
config enhance: refine exists log print with ctx (#38080) 2024-12-14 22:36:44 +08:00
eventlog fix: fix `make generate-mockery` panic with go1.22 (#36830) 2024-10-17 12:11:31 +08:00
kv enhance: Add ctx param to KV operation interfaces (#38154) 2024-12-05 15:16:41 +08:00
log enhance: move streaming coord from datacoord to rootcoord (#39009) 2025-01-07 17:56:56 +08:00
metrics enhance: [2.5]Add missing delete metrics (#38634) (#38747) 2025-01-07 11:20:56 +08:00
mocks enhance: Add ctx param to KV operation interfaces (#38154) 2024-12-05 15:16:41 +08:00
mq fix: kafka use shared channel to receive produce result (#38532) 2024-12-17 23:10:45 +08:00
streaming enhance: refactor the consumer grpc proto for reusing grpc stream for multi-consumer (#37564) 2024-11-11 17:24:29 +08:00
tracer fix: Fix tracing config update logic (#35928) 2024-09-05 14:27:04 +08:00
util enhance: excessive disk usage logs generated if the path does not exist (#38822) 2025-01-02 14:28:53 +08:00
.mockery_pkg.yaml enhance: support single pchannel level transaction (#35289) 2024-08-19 21:22:56 +08:00
Makefile enhance: Update Makefile to generate mockery (#35517) 2024-08-16 18:44:53 +08:00
go.mod enhance: [2.5] Bump golang/x/net to v0.33 fixing security alarm (#38850) (#38932) 2025-01-03 14:50:54 +08:00
go.sum enhance: [2.5] Bump golang/x/net to v0.33 fixing security alarm (#38850) (#38932) 2025-01-03 14:50:54 +08:00
rules.go Add back `gocritic` linter and fix related issues (#27289) 2023-09-22 10:05:26 +08:00