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 



33
34
35
36
37
38
39
 
# File 'lib/sqeduler/worker/synchronization.rb', line 33

def sync_lock_key(*args)
  if args.empty?
    name
  else
    "#{name}-#{args.join}"
  end
end

#synchronize(mode, opts = {}) ⇒ Object

Raises:

  • (ArgumentError) 


24
25
26
27
28
29
30
31
 
# File 'lib/sqeduler/worker/synchronization.rb', line 24

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