class SidekiqUniqueJobs::Orphans::Reaper


@author Mikael Henriksson <mikael@mhenrixon.com>
@note this is a much slower version of the lua script but does not crash redis
Class DeleteOrphans provides deletion of orphaned digests

def self.call(conn = nil)

Returns:
  • (void) -

Parameters:
  • conn (Redis) -- nil a connection to redis 
def self.call(conn = nil)
  return new(conn).call if conn
  redis { |rcon| new(rcon).call }
end

def call

Returns:
  • (Integer) - the number of reaped locks 
def call
  if (implementation = REAPERS[reaper])
    implementation.new(conn).call
  else
    log_fatal(":#{reaper} is invalid for `SidekiqUnqiueJobs.config.reaper`")
  end
end

def config

Returns:
  • (SidekiqUniqueJobs::Config) - 
def config
  SidekiqUniqueJobs.config
end

def initialize(conn)

Parameters:
  • conn (Redis) -- a connection to redis 
def initialize(conn)
  @conn = conn
end

def reaper

Returns:
  • (Symbol) - 
def reaper
  config.reaper
end

def reaper_count

Returns:
  • (Integer) - 
def reaper_count
  config.reaper_count
end