-
Notifications
You must be signed in to change notification settings - Fork 1.6k
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
[chore] Rename disabled queue to waiting queue, implement size limit #12652
base: main
Are you sure you want to change the base?
Conversation
Signed-off-by: Bogdan Drutu <[email protected]>
Codecov ReportAttention: Patch coverage is
❌ Your patch check has failed because the patch coverage (86.36%) is below the target coverage (95.00%). You can increase the patch coverage or adjust the target coverage. Additional details and impacted files@@ Coverage Diff @@
## main #12652 +/- ##
==========================================
- Coverage 91.63% 91.61% -0.03%
==========================================
Files 479 479
Lines 26423 26452 +29
==========================================
+ Hits 24214 24234 +20
- Misses 1749 1755 +6
- Partials 460 463 +3 ☔ View full report in Codecov by Sentry. 🚀 New features to boost your workflow:
|
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.
If this were only the renaming, I'd agree it's a chore not needing a changelog. But the new condition variable... I would add a changelog about the size limit. If a user is using queue-disabled today, does the condition variable mean slightly more synchronization cost? I'm trying to imagine a user who might like to read that changelog.
|
||
func (wq *waitingQueue[T]) Offer(ctx context.Context, el T) error { | ||
elSize := wq.sizer.Sizeof(el) | ||
// Ignore empty requests. |
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.
// Ignore empty requests. | |
// Ignore empty requests, see https://github.com/open-telemetry/opentelemetry-proto/blob/main/docs/specification.md#empty-telemetry-envelopes |
Because the "size limit" is max int64, it will never get to the Wait() path, and then it means the Signal path if a if check, see from https://github.com/open-telemetry/opentelemetry-collector/blob/main/exporter/exporterqueue/cond.go:
|
No need yet for changelog entry because this is not enabled, pending the new queue-batch config.