——– BEGIN keys ——— local digest = KEYS local queued = KEYS local primed = KEYS local locked = KEYS local info = KEYS local changelog = KEYS local digests = KEYS ——– END keys ———
——– BEGIN lock arguments ——— local job_id = ARGV local pttl = tonumber(ARGV) local lock_type = ARGV local limit = tonumber(ARGV) local lock_score = ARGV ——– END lock arguments ———–
——– BEGIN injected arguments ——– local current_time = tonumber(ARGV) local debug_lua = tostring(ARGV) == “1” local max_history = tonumber(ARGV) local script_name = tostring(ARGV) .. “.lua” local redisversion = tostring(ARGV) ——— END injected arguments ———
——– BEGIN local functions ——– <%= include_partial “shared/_common.lua” %> ———- END local functions ———-
——– BEGIN delete.lua ——– log_debug(“BEGIN delete”, digest)
local redis_version = toversion(redisversion) local count = 0
log_debug(“ZREM”, digests, digest) count = count + redis.call(“ZREM”, digests, digest)
log_debug(“UNLINK”, digest, queued, primed, locked, info) count = count + redis.call(“UNLINK”, digest, queued, primed, locked, info)
log(“Deleted (” .. count .. “) keys”) log_debug(“END delete (” .. count .. “) keys for:”, digest)
return count ——– END delete.lua ——–