Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

enhance: unmashall ts msg in dispatcher instead in msgstream #38656

Open
wants to merge 2 commits into
base: master
Choose a base branch
from
+771 −225

fix dispatcher

ec7ee1b
Select commit
Loading
Failed to load commit list.
Open

enhance: unmashall ts msg in dispatcher instead in msgstream #38656

fix dispatcher
ec7ee1b
Select commit
Loading
Failed to load commit list.
Codecov / codecov/patch failed Jan 16, 2025 in 0s

69.73% of diff hit (target 80.00%)

View this Pull Request on Codecov

69.73% of diff hit (target 80.00%)

Annotations

Check warning on line 735 in internal/querynodev2/delegator/delegator_data.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querynodev2/delegator/delegator_data.go#L734-L735 

Added lines #L734 - L735 were not covered by tests

Check warning on line 313 in pkg/mq/msgdispatcher/dispatcher.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/mq/msgdispatcher/dispatcher.go#L312-L313 

Added lines #L312 - L313 were not covered by tests

Check warning on line 327 in pkg/mq/msgdispatcher/dispatcher.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/mq/msgdispatcher/dispatcher.go#L326-L327 

Added lines #L326 - L327 were not covered by tests

Check warning on line 470 in pkg/mq/msgstream/mq_msgstream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/mq/msgstream/mq_msgstream.go#L467-L470 

Added lines #L467 - L470 were not covered by tests

Check warning on line 854 in pkg/mq/msgstream/mq_msgstream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/mq/msgstream/mq_msgstream.go#L851-L854 

Added lines #L851 - L854 were not covered by tests

Check warning on line 990 in pkg/mq/msgstream/mq_msgstream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/mq/msgstream/mq_msgstream.go#L987-L990 

Added lines #L987 - L990 were not covered by tests

Check warning on line 684 in pkg/mq/msgstream/msg.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/mq/msgstream/msg.go#L683-L684 

Added lines #L683 - L684 were not covered by tests

Check warning on line 96 in pkg/mq/msgstream/msgstream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/mq/msgstream/msgstream.go#L95-L96 

Added lines #L95 - L96 were not covered by tests

Check warning on line 104 in pkg/mq/msgstream/msgstream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/mq/msgstream/msgstream.go#L103-L104 

Added lines #L103 - L104 were not covered by tests

Check warning on line 108 in pkg/mq/msgstream/msgstream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/mq/msgstream/msgstream.go#L107-L108 

Added lines #L107 - L108 were not covered by tests

Check warning on line 112 in pkg/mq/msgstream/msgstream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/mq/msgstream/msgstream.go#L111-L112 

Added lines #L111 - L112 were not covered by tests

Check warning on line 116 in pkg/mq/msgstream/msgstream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/mq/msgstream/msgstream.go#L115-L116 

Added lines #L115 - L116 were not covered by tests

Check warning on line 124 in pkg/mq/msgstream/msgstream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/mq/msgstream/msgstream.go#L123-L124 

Added lines #L123 - L124 were not covered by tests

Check warning on line 132 in pkg/mq/msgstream/msgstream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/mq/msgstream/msgstream.go#L130-L132 

Added lines #L130 - L132 were not covered by tests

Check warning on line 137 in pkg/mq/msgstream/msgstream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/mq/msgstream/msgstream.go#L136-L137 

Added lines #L136 - L137 were not covered by tests

Check warning on line 141 in pkg/mq/msgstream/msgstream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/mq/msgstream/msgstream.go#L140-L141 

Added lines #L140 - L141 were not covered by tests

Check warning on line 145 in pkg/mq/msgstream/msgstream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/mq/msgstream/msgstream.go#L144-L145 

Added lines #L144 - L145 were not covered by tests

Check warning on line 218 in pkg/mq/msgstream/msgstream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/mq/msgstream/msgstream.go#L217-L218 

Added lines #L217 - L218 were not covered by tests

Check warning on line 229 in pkg/mq/msgstream/msgstream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/mq/msgstream/msgstream.go#L228-L229 

Added lines #L228 - L229 were not covered by tests

Check warning on line 234 in pkg/mq/msgstream/msgstream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/mq/msgstream/msgstream.go#L233-L234 

Added lines #L233 - L234 were not covered by tests

Check warning on line 239 in pkg/mq/msgstream/msgstream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/mq/msgstream/msgstream.go#L238-L239 

Added lines #L238 - L239 were not covered by tests

Check warning on line 245 in pkg/mq/msgstream/msgstream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/mq/msgstream/msgstream.go#L243-L245 

Added lines #L243 - L245 were not covered by tests

Check warning on line 250 in pkg/mq/msgstream/msgstream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/mq/msgstream/msgstream.go#L249-L250 

Added lines #L249 - L250 were not covered by tests

Check warning on line 256 in pkg/mq/msgstream/msgstream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/mq/msgstream/msgstream.go#L254-L256 

Added lines #L254 - L256 were not covered by tests

Check warning on line 261 in pkg/mq/msgstream/msgstream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/mq/msgstream/msgstream.go#L260-L261 

Added lines #L260 - L261 were not covered by tests
View more details on Codecov