-
Notifications
You must be signed in to change notification settings - Fork 3k
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.
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: Introduce batch subscription in msgdispatcher #39863
base: master
Are you sure you want to change the base?
Conversation
Signed-off-by: bigsheeper <[email protected]>
[APPROVALNOTIFIER] This PR is NOT APPROVED This pull-request has been approved by: bigsheeper The full list of commands accepted by this bot can be found here.
Needs approval from an approver in each of these files:
Approvers can indicate their approval by writing |
@bigsheeper go-sdk check failed, comment |
@bigsheeper E2e jenkins job failed, comment |
Codecov ReportAll modified and coverable lines are covered by tests ✅
❌ Your project check has failed because the head coverage (69.58%) is below the target coverage (77.00%). You can increase the head coverage or adjust the target coverage.
Additional details and impacted files@@ Coverage Diff @@
## master #39863 +/- ##
===========================================
- Coverage 79.76% 69.58% -10.19%
===========================================
Files 1500 305 -1195
Lines 207393 27344 -180049
===========================================
- Hits 165435 19027 -146408
+ Misses 35927 8317 -27610
+ Partials 6031 0 -6031
|
/run-cpu-e2e |
Signed-off-by: bigsheeper <[email protected]>
Signed-off-by: bigsheeper <[email protected]>
…2-dispatcher-queue
@bigsheeper go-sdk check failed, comment |
rerun go-sdk |
…2-dispatcher-queue
Signed-off-by: bigsheeper <[email protected]>
…2-dispatcher-queue
…2-dispatcher-queue
…2-dispatcher-queue
Signed-off-by: bigsheeper <[email protected]>
…2-dispatcher-queue
Introduce a batch subscription mechanism in msgdispatcher: the msgdispatcher now includes a vchannel watch task queue, where all vchannels in the queue will subscribe to the MQ only once and pull messages from the oldest vchannel checkpoint to the latest.
issue: #39862