rckrdmrd
50a821a415
- HERENCIA-SIMCO.md actualizado con directivas v3.7 y v3.8 - Actualizaciones de configuracion Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
43 lines
1.1 KiB
JavaScript
43 lines
1.1 KiB
JavaScript
"use strict";
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
|
exports.QueueKeys = void 0;
|
|
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}`;
|
|
}
|
|
}
|
|
exports.QueueKeys = QueueKeys;
|
|
//# sourceMappingURL=queue-keys.js.map
|