enhance: add broadcast operation for msgstream

[chyezh]

issue: #38399

• make broadcast service available for msgstream by reusing the architecture streaming service

[codecov]

Codecov Report

Attention: Patch coverage is 59.39086% with 80 lines in your changes missing coverage. Please review.

Project coverage is 81.14%. Comparing base (86d665a) to head (d108b10).

Files with missing lines	Patch %	Lines
internal/rootcoord/broadcast_task.go	8.77%	52 Missing ⚠️
...treaming/util/message/adaptor/broadcast_message.go	0.00%	12 Missing ⚠️
pkg/streaming/util/types/responses.go	86.04%	6 Missing ⚠️
internal/distributed/streaming/util.go	55.55%	4 Missing ⚠️
internal/rootcoord/dml_channels.go	0.00%	3 Missing ⚠️
...eamingcoord/server/broadcaster/broadcaster_impl.go	88.00%	2 Missing and 1 partial ⚠️

Additional details and impacted files

@@           Coverage Diff            @@
##           master   #39040    +/-   ##
========================================
  Coverage   81.13%   81.14%            
========================================
  Files        1395     1400     +5     
  Lines      197359   197492   +133     
========================================
+ Hits       160131   160245   +114     
- Misses      31599    31633    +34     
+ Partials     5629     5614    -15     

Components	Coverage Δ
Client	79.53% <ø> (ø)
Core	69.64% <ø> (ø)
Go	83.06% <59.18%> (+<0.01%)	⬆️

Files with missing lines	Coverage Δ
internal/distributed/streaming/streaming.go	100.00% <100.00%> (ø)
internal/distributed/streaming/wal.go	66.08% <100.00%> (+1.22%)	⬆️
internal/rootcoord/root_coord.go	90.09% <100.00%> (+0.01%)	⬆️
internal/streamingcoord/client/client.go	97.01% <100.00%> (+0.18%)	⬆️
internal/streamingcoord/client/client_impl.go	80.00% <100.00%> (+5.00%)	⬆️
...ord/server/broadcaster/registry/append_operator.go	100.00% <100.00%> (ø)
...gcoord/server/broadcaster/registry/test_utility.go	100.00% <100.00%> (ø)
internal/streamingcoord/server/broadcaster/task.go	100.00% <100.00%> (ø)
internal/streamingcoord/server/server.go	71.69% <100.00%> (ø)
pkg/streaming/util/types/streaming_node.go	82.35% <ø> (-2.50%)	⬇️
... and 8 more

... and 32 files with indirect coverage changes

[mergify]

@chyezh E2e jenkins job failed, comment /run-cpu-e2e can trigger the job again.

[mergify]

@chyezh go-sdk check failed, comment rerun go-sdk can trigger the job again.

[mergify]

@chyezh cpp-unit-test check failed, comment rerun cpp-unit-test can trigger the job again.

[sre-ci-robot]

[APPROVALNOTIFIER] This PR is NOT APPROVED

This pull-request has been approved by: chyezh
To complete the pull request process, please assign jiaoew1991 after the PR has been reviewed.
You can assign the PR to them by writing /assign @jiaoew1991 in a comment when ready.

The full list of commands accepted by this bot can be found here.

Needs approval from an approver in each of these files:

• cmd/OWNERS
• configs/OWNERS
• internal/distributed/streaming/OWNERS
• internal/rootcoord/OWNERS
• internal/streamingcoord/OWNERS
• pkg/streaming/OWNERS
• pkg/util/OWNERS
• tests/integration/OWNERS

Approvers can indicate their approval by writing /approve in a comment
Approvers can cancel approval by writing /approve cancel in a comment

[mergify]

@chyezh E2e jenkins job failed, comment /run-cpu-e2e can trigger the job again.

[chyezh]

rerun ut

[chyezh]

/run-cpu-e2e