module Sqeduler::Worker::Synchronization::ClassMethods

rubocop:disable Style/Documentation

Public Instance Methods

sync_lock_key(*args) click to toggle source
# File lib/sqeduler/worker/synchronization.rb, line 31
def sync_lock_key(*args)
  if args.empty?
    name
  else
    "#{name}-#{args.join}"
  end
end
synchronize(mode, opts = {}) click to toggle source
# File lib/sqeduler/worker/synchronization.rb, line 23
def synchronize(mode, opts = {})
  self.synchronize_jobs_mode = mode
  self.synchronize_jobs_timeout = opts[:timeout] || 5
  self.synchronize_jobs_expiration = opts[:expiration]
  return if synchronize_jobs_expiration
  raise ArgumentError, ":expiration is required!"
end