——– BEGIN keys ——— local digest = KEYS local queued = KEYS local primed = KEYS local locked = KEYS local run_digest = KEYS local run_queued = KEYS local run_primed = KEYS local run_locked = KEYS local digests = KEYS ——– END keys ———
——– BEGIN injected arguments ——– local current_time = tonumber(ARGV) local debug_lua = ARGV == “true” 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_by_digest.lua ——– local counter = 0 local redis_version = toversion(redisversion) local del_cmd = “DEL”
log_debug(“BEGIN delete_by_digest:”, digest)
if redis_version >= 4 then del_cmd = “UNLINK”; end
log_debug(del_cmd, digest, queued, primed, locked, run_digest, run_queued, run_primed, run_locked) counter = redis.call(del_cmd, digest, queued, primed, locked, run_digest, run_queued, run_primed, run_locked)
log_debug(“ZREM”, digests, digest) redis.call(“ZREM”, digests, digest)
log_debug(“END delete_by_digest:”, digest, “(deleted ” .. counter .. “ keys)”) return counter ——– END delete_by_digest.lua ——–