Sha256: dd3b636bbb7c15b17a5af8744855873cf752c5676e2e163b606e4bb37fb483cf
Contents?: true
Size: 1.25 KB
Versions: 14
Compression:
Stored size: 1.25 KB
Contents
# frozen_string_literal: true
module SidekiqUniqueJobs
# Utility module to help manage unique keys in redis.
# Useful for deleting keys that for whatever reason wasn't deleted
#
# @author Mikael Henriksson <mikael@zoolutions.se>
module Unlockable
module_function
# Unlocks a job.
# @param [Hash] item a Sidekiq job hash
def unlock(item)
SidekiqUniqueJobs::Job.add_digest(item)
SidekiqUniqueJobs::Locksmith.new(item).unlock
end
# Unlocks a job.
# @param [Hash] item a Sidekiq job hash
def unlock!(item)
SidekiqUniqueJobs::Job.add_digest(item)
SidekiqUniqueJobs::Locksmith.new(item).unlock!
end
# Deletes a lock unless it has ttl
#
# This is good for situations when a job is locked by another item
# @param [Hash] item a Sidekiq job hash
def delete(item)
SidekiqUniqueJobs::Job.add_digest(item)
SidekiqUniqueJobs::Locksmith.new(item).delete
end
# Deletes a lock regardless of if it was locked or has ttl.
#
# This is good for situations when a job is locked by another item
# @param [Hash] item a Sidekiq job hash
def delete!(item)
SidekiqUniqueJobs::Job.add_digest(item)
SidekiqUniqueJobs::Locksmith.new(item).delete!
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems