Sha256: fc60267a2a23edf1cd3e4dc4505c49facd4ddefa3997cc2131bbb558dcbe3964
Contents?: true
Size: 683 Bytes
Versions: 38
Compression:
Stored size: 683 Bytes
Contents
# frozen_string_literal: true module SidekiqUniqueJobs module Orphans # # Class DeleteOrphans provides deletion of orphaned digests # # @note this is a much slower version of the lua script but does not crash redis # # @author Mikael Henriksson <mikael@mhenrixon.com> # class LuaReaper < Reaper # # Delete orphaned digests # # # @return [Integer] the number of reaped locks # def call call_script( :reap_orphans, conn, keys: [DIGESTS, SCHEDULE, RETRY, PROCESSES], argv: [reaper_count, (Time.now - reaper_timeout).to_f], ) end end end end
Version data entries
38 entries across 38 versions & 1 rubygems