| 123456789101112131415161718192021222324252627282930313233343536373839 |
- export class QueueKeys {
- constructor(prefix = 'bull') {
- this.prefix = prefix;
- }
- getKeys(name) {
- const keys = {};
- [
- '',
- 'active',
- 'wait',
- 'waiting-children',
- 'paused',
- 'id',
- 'delayed',
- 'prioritized',
- 'stalled-check',
- 'completed',
- 'failed',
- 'stalled',
- 'repeat',
- 'limiter',
- 'meta',
- 'events',
- 'pc', // priority counter key
- 'marker', // marker key
- 'de', // deduplication key
- ].forEach(key => {
- keys[key] = this.toKey(name, key);
- });
- return keys;
- }
- toKey(name, type) {
- return `${this.getQueueQualifiedName(name)}:${type}`;
- }
- getQueueQualifiedName(name) {
- return `${this.prefix}:${name}`;
- }
- }
- //# sourceMappingURL=queue-keys.js.map
|