telemetry-attributes.d.ts 2.4 KB

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