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

Version Path
sidekiq-unique-jobs-7.1.25 lib/sidekiq_unique_jobs/orphans/lua_reaper.rb
sidekiq-unique-jobs-7.1.24 lib/sidekiq_unique_jobs/orphans/lua_reaper.rb
sidekiq-unique-jobs-7.1.23 lib/sidekiq_unique_jobs/orphans/lua_reaper.rb
sidekiq-unique-jobs-7.1.22 lib/sidekiq_unique_jobs/orphans/lua_reaper.rb
sidekiq-unique-jobs-7.1.21 lib/sidekiq_unique_jobs/orphans/lua_reaper.rb
sidekiq-unique-jobs-7.1.20 lib/sidekiq_unique_jobs/orphans/lua_reaper.rb
sidekiq-unique-jobs-7.1.19 lib/sidekiq_unique_jobs/orphans/lua_reaper.rb
sidekiq-unique-jobs-7.1.18 lib/sidekiq_unique_jobs/orphans/lua_reaper.rb
sidekiq-unique-jobs-7.1.17 lib/sidekiq_unique_jobs/orphans/lua_reaper.rb
sidekiq-unique-jobs-7.1.16 lib/sidekiq_unique_jobs/orphans/lua_reaper.rb
sidekiq-unique-jobs-7.1.15 lib/sidekiq_unique_jobs/orphans/lua_reaper.rb
sidekiq-unique-jobs-7.1.14 lib/sidekiq_unique_jobs/orphans/lua_reaper.rb
sidekiq-unique-jobs-7.1.13 lib/sidekiq_unique_jobs/orphans/lua_reaper.rb
sidekiq-unique-jobs-7.1.12 lib/sidekiq_unique_jobs/orphans/lua_reaper.rb
sidekiq-unique-jobs-7.1.11 lib/sidekiq_unique_jobs/orphans/lua_reaper.rb
sidekiq-unique-jobs-7.1.10 lib/sidekiq_unique_jobs/orphans/lua_reaper.rb
sidekiq-unique-jobs-7.1.8 lib/sidekiq_unique_jobs/orphans/lua_reaper.rb
sidekiq-unique-jobs-7.0.13 lib/sidekiq_unique_jobs/orphans/lua_reaper.rb
sidekiq-unique-jobs-7.1.7 lib/sidekiq_unique_jobs/orphans/lua_reaper.rb
sidekiq-unique-jobs-7.1.6 lib/sidekiq_unique_jobs/orphans/lua_reaper.rb