telemetry-attributes.js 3.7 KB

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