enhance: unmashall ts msg in dispatcher instead in msgstream

[aoiasd]

relate: #38655

[sre-ci-robot]

[APPROVALNOTIFIER] This PR is NOT APPROVED

This pull-request has been approved by: aoiasd
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:

• OWNERS

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

[mergify]

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

[mergify]

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

[mergify]

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

[codecov]

Codecov Report

Attention: Patch coverage is 69.73294% with 102 lines in your changes missing coverage. Please review.

Project coverage is 81.01%. Comparing base (bca2a62) to head (ec7ee1b).
Report is 4 commits behind head on master.

Files with missing lines	Patch %	Lines
pkg/mq/msgstream/msgstream.go	59.65%	59 Missing and 12 partials ⚠️
pkg/mq/msgstream/mq_msgstream.go	83.95%	12 Missing and 1 partial ⚠️
pkg/mq/msgdispatcher/dispatcher.go	78.57%	4 Missing and 2 partials ⚠️
internal/querynodev2/delegator/delegator_data.go	50.00%	2 Missing and 1 partial ⚠️
pkg/mq/msgstream/msgstream_util.go	85.00%	2 Missing and 1 partial ⚠️
pkg/mq/msgstream/trace.go	40.00%	3 Missing ⚠️
pkg/mq/msgstream/msg.go	90.00%	2 Missing ⚠️
pkg/mq/msgstream/wasted_mock_msgstream.go	0.00%	1 Missing ⚠️

Additional details and impacted files

@@             Coverage Diff             @@
##           master   #38656       +/-   ##
===========================================
+ Coverage   69.63%   81.01%   +11.37%     
===========================================
  Files         299     1407     +1108     
  Lines       26807   198757   +171950     
===========================================
+ Hits        18668   161019   +142351     
- Misses       8139    32077    +23938     
- Partials        0     5661     +5661     

Components	Coverage Δ
Client	79.50% <ø> (∅)
Core	69.48% <ø> (-0.16%)	⬇️
Go	82.94% <69.73%> (∅)

Files with missing lines	Coverage Δ
pkg/mq/common/message.go	38.09% <ø> (ø)
pkg/mq/msgstream/wasted_mock_msgstream.go	75.00% <0.00%> (ø)
pkg/mq/msgstream/msg.go	80.72% <90.00%> (ø)
internal/querynodev2/delegator/delegator_data.go	84.51% <50.00%> (ø)
pkg/mq/msgstream/msgstream_util.go	56.86% <85.00%> (ø)
pkg/mq/msgstream/trace.go	61.90% <40.00%> (ø)
pkg/mq/msgdispatcher/dispatcher.go	90.32% <78.57%> (ø)
pkg/mq/msgstream/mq_msgstream.go	79.03% <83.95%> (ø)
pkg/mq/msgstream/msgstream.go	65.36% <59.65%> (ø)

... and 1112 files with indirect coverage changes

[mergify]

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

[mergify]

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

[mergify]

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

[mergify]

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

[mergify]

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

[mergify]

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

[aoiasd]

rerun cpp-unit-test

[aoiasd]

/run-cpu-e2e

[aoiasd]

rerun go-sdk