telemetry-attributes.js 3.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869
  1. "use strict";
  2. Object.defineProperty(exports, "__esModule", { value: true });
  3. exports.SpanKind = exports.MetricNames = exports.TelemetryAttributes = void 0;
  4. var TelemetryAttributes;
  5. (function (TelemetryAttributes) {
  6. TelemetryAttributes["QueueName"] = "bullmq.queue.name";
  7. TelemetryAttributes["QueueOperation"] = "bullmq.queue.operation";
  8. TelemetryAttributes["BulkCount"] = "bullmq.job.bulk.count";
  9. TelemetryAttributes["BulkNames"] = "bullmq.job.bulk.names";
  10. TelemetryAttributes["JobName"] = "bullmq.job.name";
  11. TelemetryAttributes["JobId"] = "bullmq.job.id";
  12. TelemetryAttributes["JobKey"] = "bullmq.job.key";
  13. TelemetryAttributes["JobIds"] = "bullmq.job.ids";
  14. TelemetryAttributes["JobAttemptsMade"] = "bullmq.job.attempts.made";
  15. TelemetryAttributes["DeduplicationKey"] = "bullmq.job.deduplication.key";
  16. TelemetryAttributes["JobOptions"] = "bullmq.job.options";
  17. TelemetryAttributes["JobProgress"] = "bullmq.job.progress";
  18. TelemetryAttributes["QueueDrainDelay"] = "bullmq.queue.drain.delay";
  19. TelemetryAttributes["QueueGrace"] = "bullmq.queue.grace";
  20. TelemetryAttributes["QueueCleanLimit"] = "bullmq.queue.clean.limit";
  21. TelemetryAttributes["QueueRateLimit"] = "bullmq.queue.rate.limit";
  22. TelemetryAttributes["JobType"] = "bullmq.job.type";
  23. TelemetryAttributes["QueueOptions"] = "bullmq.queue.options";
  24. TelemetryAttributes["QueueEventMaxLength"] = "bullmq.queue.event.max.length";
  25. TelemetryAttributes["QueueJobsState"] = "bullmq.queue.jobs.state";
  26. TelemetryAttributes["WorkerOptions"] = "bullmq.worker.options";
  27. TelemetryAttributes["WorkerName"] = "bullmq.worker.name";
  28. TelemetryAttributes["WorkerId"] = "bullmq.worker.id";
  29. TelemetryAttributes["WorkerRateLimit"] = "bullmq.worker.rate.limit";
  30. TelemetryAttributes["WorkerDoNotWaitActive"] = "bullmq.worker.do.not.wait.active";
  31. TelemetryAttributes["WorkerForceClose"] = "bullmq.worker.force.close";
  32. TelemetryAttributes["WorkerStalledJobs"] = "bullmq.worker.stalled.jobs";
  33. TelemetryAttributes["WorkerFailedJobs"] = "bullmq.worker.failed.jobs";
  34. TelemetryAttributes["WorkerJobsToExtendLocks"] = "bullmq.worker.jobs.to.extend.locks";
  35. /**
  36. * @deprecated Use JobAttemptFinishedTimestamp instead. Will be removed in a future version.
  37. */
  38. TelemetryAttributes["JobFinishedTimestamp"] = "bullmq.job.finished.timestamp";
  39. TelemetryAttributes["JobAttemptFinishedTimestamp"] = "bullmq.job.attempt_finished_timestamp";
  40. TelemetryAttributes["JobProcessedTimestamp"] = "bullmq.job.processed.timestamp";
  41. TelemetryAttributes["JobResult"] = "bullmq.job.result";
  42. TelemetryAttributes["JobFailedReason"] = "bullmq.job.failed.reason";
  43. TelemetryAttributes["FlowName"] = "bullmq.flow.name";
  44. TelemetryAttributes["JobSchedulerId"] = "bullmq.job.scheduler.id";
  45. TelemetryAttributes["JobStatus"] = "bullmq.job.status";
  46. })(TelemetryAttributes || (exports.TelemetryAttributes = TelemetryAttributes = {}));
  47. /**
  48. * Standard metric names for BullMQ telemetry
  49. */
  50. var MetricNames;
  51. (function (MetricNames) {
  52. MetricNames["QueueJobsCount"] = "bullmq.queue.jobs";
  53. MetricNames["JobsCompleted"] = "bullmq.jobs.completed";
  54. MetricNames["JobsFailed"] = "bullmq.jobs.failed";
  55. MetricNames["JobsDelayed"] = "bullmq.jobs.delayed";
  56. MetricNames["JobsRetried"] = "bullmq.jobs.retried";
  57. MetricNames["JobsWaiting"] = "bullmq.jobs.waiting";
  58. MetricNames["JobsWaitingChildren"] = "bullmq.jobs.waiting_children";
  59. MetricNames["JobDuration"] = "bullmq.job.duration";
  60. })(MetricNames || (exports.MetricNames = MetricNames = {}));
  61. var SpanKind;
  62. (function (SpanKind) {
  63. SpanKind[SpanKind["INTERNAL"] = 0] = "INTERNAL";
  64. SpanKind[SpanKind["SERVER"] = 1] = "SERVER";
  65. SpanKind[SpanKind["CLIENT"] = 2] = "CLIENT";
  66. SpanKind[SpanKind["PRODUCER"] = 3] = "PRODUCER";
  67. SpanKind[SpanKind["CONSUMER"] = 4] = "CONSUMER";
  68. })(SpanKind || (exports.SpanKind = SpanKind = {}));
  69. //# sourceMappingURL=telemetry-attributes.js.map