module SidekiqUniqueJobs::Job
Utility class to append uniqueness to the sidekiq job hash
@author Mikael Henriksson <mikael@mhenrixon.com>
Public Instance Methods
Source
# File lib/sidekiq_unique_jobs/job.rb, line 22 def add_digest(item) add_lock_prefix(item) add_lock_args(item) add_lock_digest(item) item end
Adds lock_args, lock_prefix and lock_digest to the sidekiq job hash @return [Hash] the job hash
Source
# File lib/sidekiq_unique_jobs/job.rb, line 12 def prepare(item) stringify_on_conflict_hash(item) add_lock_type(item) add_lock_timeout(item) add_lock_ttl(item) add_digest(item) end
Adds lock, timeout, expiration, lock_args, lock_prefix, and lock_digest to the sidekiq job hash @return [Hash] the job hash
Private Instance Methods
Source
# File lib/sidekiq_unique_jobs/job.rb, line 47 def add_lock_args(item) item[LOCK_ARGS] = SidekiqUniqueJobs::LockArgs.call(item) end
Source
# File lib/sidekiq_unique_jobs/job.rb, line 51 def add_lock_digest(item) item[LOCK_DIGEST] = SidekiqUniqueJobs::LockDigest.call(item) end
Source
# File lib/sidekiq_unique_jobs/job.rb, line 55 def add_lock_prefix(item) item[LOCK_PREFIX] = SidekiqUniqueJobs.config.lock_prefix end
Source
# File lib/sidekiq_unique_jobs/job.rb, line 43 def add_lock_timeout(item) item[LOCK_TIMEOUT] = SidekiqUniqueJobs::LockTimeout.calculate(item) end
Source
# File lib/sidekiq_unique_jobs/job.rb, line 39 def add_lock_ttl(item) item[LOCK_TTL] = SidekiqUniqueJobs::LockTTL.calculate(item) end
Source
# File lib/sidekiq_unique_jobs/job.rb, line 59 def add_lock_type(item) item[LOCK] ||= SidekiqUniqueJobs::LockType.call(item) end
Source
# File lib/sidekiq_unique_jobs/job.rb, line 32 def stringify_on_conflict_hash(item) on_conflict = item[ON_CONFLICT] return unless on_conflict.is_a?(Hash) item[ON_CONFLICT] = on_conflict.deep_stringify_keys end