Sha256: f2f9d798b8f6f3ced12f8533e73461a7dfc6df7c43f4e9b610dbcfb9d627cb7b
Contents?: true
Size: 1.06 KB
Versions: 76
Compression:
Stored size: 1.06 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 = ARGV[3] == "true" 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
76 entries across 76 versions & 1 rubygems