Zhen Ye f2e581e2d7

enhance: add broadcast for streaming service (#39047) ...

issue: #38399
pr: #39020

- Add new rpc for transfer broadcast to streaming coord
- Add broadcast service at streaming coord to make broadcast message
sent automicly

also cherry pick the pr #38400

---------

Signed-off-by: chyezh <chyezh@outlook.com>

2025-01-09 16:46: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: add broadcast for streaming service (#39047)

2025-01-09 16:46:56 +08:00

tracer

fix: Fix tracing config update logic (#35928)

2024-09-05 14:27:04 +08:00

util

enhance: add broadcast for streaming service (#39047)

2025-01-09 16:46:56 +08:00

.mockery_pkg.yaml

enhance: support single pchannel level transaction (#35289)

2024-08-19 21:22:56 +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

Makefile

enhance: Update Makefile to generate mockery (#35517)

2024-08-16 18:44:53 +08:00

rules.go

Add back gocritic linter and fix related issues (#27289)

2023-09-22 10:05:26 +08:00