-
Notifications
You must be signed in to change notification settings - Fork 424
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(telemetry): metrics #2959
base: master
Are you sure you want to change the base?
feat(telemetry): metrics #2959
Conversation
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.
I think this PR is not ready as the metrics are not being actually used in the code. I added some other comments.
@@ -1,30 +1,36 @@ | |||
<!-- | |||
Thank you for submitting a PR! | |||
Thank you for submitting a PR! |
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.
Please make sure to not reformat unrelated files.
* [v3](changelogs/changelog-v3.md) | ||
* [v2](changelogs/changelog-v2.md) | ||
* [v1](changelogs/changelog-v1.md) | ||
- [What is BullMQ](README.md) |
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.
Do not reformat unrelated files.
import { SpanKind, ValueType } from '../enums'; | ||
|
||
/** | ||
* Configuration for bullmqOtel package. |
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.
Even though this will be now used by the bullmq-otel package, it is should not be specifically for this package.
* Configuration for bullmqOtel package. | ||
* Used for tracing and metrics. | ||
*/ | ||
export interface Configuration { |
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.
Configuration is a way too generic name for an interface.
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.
I could not find where Configuration is used in the code, so what is its purpose?
flow.queueName, | ||
'addFlow', | ||
flow.queueName, | ||
return telemetry<Promise<JobNode>>( |
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.
I am very confused about this name change, now we have both a telemetry object and a telemetry function. Besides, the best practice is to name functions as verbs, and in this case it is a substantive, so it is not clear what the function does by its name alone.
No description provided.