58f8093689
- Updated all component headers and documentation
- Changed navbar and footer branding
- Updated homepage hero badge
- Modified page title in index.html
- Simplified footer text to 'Built with ❤️'
- Consistent V2 capitalization across all references
41 lines
1.0 KiB
JavaScript
41 lines
1.0 KiB
JavaScript
"use strict";
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
|
exports.changeDelay = void 0;
|
|
const content = `--[[
|
|
Change job delay when it is in delayed set.
|
|
Input:
|
|
KEYS[1] delayed key
|
|
KEYS[2] job key
|
|
KEYS[3] events stream
|
|
ARGV[1] delay
|
|
ARGV[2] delayedTimestamp
|
|
ARGV[3] the id of the job
|
|
Output:
|
|
0 - OK
|
|
-1 - Missing job.
|
|
-3 - Job not in delayed set.
|
|
Events:
|
|
- delayed key.
|
|
]]
|
|
local rcall = redis.call
|
|
if rcall("EXISTS", KEYS[2]) == 1 then
|
|
local jobId = ARGV[3]
|
|
local score = tonumber(ARGV[2])
|
|
local delayedTimestamp = (score / 0x1000)
|
|
local numRemovedElements = rcall("ZREM", KEYS[1], jobId)
|
|
if numRemovedElements < 1 then
|
|
return -3
|
|
end
|
|
rcall("HSET", KEYS[2], "delay", tonumber(ARGV[1]))
|
|
rcall("ZADD", KEYS[1], score, jobId)
|
|
rcall("XADD", KEYS[3], "*", "event", "delayed", "jobId", jobId, "delay", delayedTimestamp)
|
|
return 0
|
|
else
|
|
return -1
|
|
end`;
|
|
exports.changeDelay = {
|
|
name: 'changeDelay',
|
|
content,
|
|
keys: 3,
|
|
};
|
|
//# sourceMappingURL=changeDelay-3.js.map
|