Sha256: 7eeed05a8b1d728261d4eff714e5b14ccd8a551f971e9dc4c05c66489b46b125
Contents?: true
Size: 1.07 KB
Versions: 9
Compression:
Stored size: 1.07 KB
Contents
-------- BEGIN keys --------- local queue = KEYS[1] local schedule_set = KEYS[2] local retry_set = KEYS[3] -------- END keys --------- -------- BEGIN Arguments --------- local digest = ARGV[1] -------- END Arguments --------- -------- BEGIN injected arguments -------- local current_time = tonumber(ARGV[2]) local debug_lua = tostring(ARGV[3]) == "1" local max_history = tonumber(ARGV[4]) local script_name = tostring(ARGV[5]) .. ".lua" --------- END injected arguments --------- -------- BEGIN local functions -------- <%= include_partial "shared/_common.lua" %> <%= include_partial "shared/_delete_from_queue.lua" %> <%= include_partial "shared/_delete_from_sorted_set.lua" %> ---------- END local functions ---------- -------- BEGIN delete_job_by_digest.lua -------- local result = delete_from_queue(queue, digest) if result then return result end result = delete_from_sorted_set(schedule_set, digest) if result then return result end result = delete_from_sorted_set(retry_set, digest) return result -------- END delete_job_by_digest.lua --------
Version data entries
9 entries across 9 versions & 1 rubygems