removeZSetJobs.lua 532 B

123456789101112131415161718192021
  1. -- Includes
  2. --- @include "batches"
  3. --- @include "filterOutJobsToIgnore"
  4. --- @include "getZSetItems"
  5. --- @include "removeJobs"
  6. local function removeZSetJobs(keyName, hard, baseKey, max, jobsToIgnore)
  7. local jobs = getZSetItems(keyName, max)
  8. if jobsToIgnore then
  9. jobs = filterOutJobsToIgnore(jobs, jobsToIgnore)
  10. end
  11. local count = removeJobs(jobs, hard, baseKey, max)
  12. if(#jobs > 0) then
  13. for from, to in batches(#jobs, 7000) do
  14. rcall("ZREM", keyName, unpack(jobs, from, to))
  15. end
  16. end
  17. return count
  18. end