class RubyJob::JobStore
Public Class Methods
new()
click to toggle source
# File lib/ruby_job/job_store.rb, line 5 def initialize @options = { wait: true, wait_delay: 0.5 } end
Public Instance Methods
dequeue(_job)
click to toggle source
# File lib/ruby_job/job_store.rb, line 21 def dequeue(_job) raise NotImplementedError end
enqueue(_job)
click to toggle source
# File lib/ruby_job/job_store.rb, line 17 def enqueue(_job) raise NotImplementedError end
fetch(*)
click to toggle source
# File lib/ruby_job/job_store.rb, line 29 def fetch(*) raise NotImplementedError end
next_uuid()
click to toggle source
# File lib/ruby_job/job_store.rb, line 37 def next_uuid raise NotImplementedError end
pause_at(_time)
click to toggle source
# File lib/ruby_job/job_store.rb, line 25 def pause_at(_time) raise NotImplementedError end
set(**options)
click to toggle source
# File lib/ruby_job/job_store.rb, line 12 def set(**options) @options.merge!(**options) self end
size()
click to toggle source
# File lib/ruby_job/job_store.rb, line 33 def size raise NotImplementedError end