Module: Sqeduler::Worker::Synchronization::ClassMethods

Defined in:
lib/sqeduler/worker/synchronization.rb

Overview

rubocop:disable Style/Documentation

Instance Method Summary collapse

Instance Method Details

#sync_lock_key(*args) ⇒ Object 



31
32
33
34
35
36
37
 
# 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 = {}) ⇒ Object 



23
24
25
26
27
28
29
 
# 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
  fail ArgumentError, ":expiration is required!"
end