queue-keys.js 960 B

123456789101112131415161718192021222324252627282930313233343536373839
  1. export class QueueKeys {
  2. constructor(prefix = 'bull') {
  3. this.prefix = prefix;
  4. }
  5. getKeys(name) {
  6. const keys = {};
  7. [
  8. '',
  9. 'active',
  10. 'wait',
  11. 'waiting-children',
  12. 'paused',
  13. 'id',
  14. 'delayed',
  15. 'prioritized',
  16. 'stalled-check',
  17. 'completed',
  18. 'failed',
  19. 'stalled',
  20. 'repeat',
  21. 'limiter',
  22. 'meta',
  23. 'events',
  24. 'pc', // priority counter key
  25. 'marker', // marker key
  26. 'de', // deduplication key
  27. ].forEach(key => {
  28. keys[key] = this.toKey(name, key);
  29. });
  30. return keys;
  31. }
  32. toKey(name, type) {
  33. return `${this.getQueueQualifiedName(name)}:${type}`;
  34. }
  35. getQueueQualifiedName(name) {
  36. return `${this.prefix}:${name}`;
  37. }
  38. }
  39. //# sourceMappingURL=queue-keys.js.map