-
Notifications
You must be signed in to change notification settings - Fork 2
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
feat: update rdr codes for dropped message #232
Conversation
For dropped messages, dispose of the payload and update the rdr code to the following: - rdr value of 4 for payloads too large - rdr value of 102 for lower priority messages
438d579
to
fcaeb57
Compare
Codecov ReportAll modified and coverable lines are covered by tests ✅
Additional details and impacted files@@ Coverage Diff @@
## main #232 +/- ##
=======================================
Coverage 77.55% 77.56%
=======================================
Files 74 74
Lines 4625 4626 +1
=======================================
+ Hits 3587 3588 +1
Misses 841 841
Partials 197 197
Flags with carried forward coverage won't be shown. Click here to find out more. ☔ View full report in Codecov by Sentry. |
itm := heap.Pop(pq).(item) | ||
// itm.discard will be true if `itm` has been marked to be discarded, | ||
// i.e. trimmed by `pq.trim()'. | ||
if itm.discard { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Previously we were discarding the message without sending any response back to xmidt
For dropped messages, dispose of the payload and update the rdr code to the following: