Class: RubyJob::JobStore
- Inherits:
-
Object
- Object
- RubyJob::JobStore
- Defined in:
- lib/ruby_job/job_store.rb
Direct Known Subclasses
Instance Method Summary collapse
- #dequeue(_job) ⇒ Object
- #enqueue(_job) ⇒ Object
- #fetch ⇒ Object
-
#initialize ⇒ JobStore
constructor
A new instance of JobStore.
- #next_uuid ⇒ Object
- #pause_at(_time) ⇒ Object
- #set(**options) ⇒ Object
- #size ⇒ Object
Constructor Details
#initialize ⇒ JobStore
Returns a new instance of JobStore.
5 6 7 8 9 10 |
# File 'lib/ruby_job/job_store.rb', line 5 def initialize @options = { wait: true, wait_delay: 0.5 } end |
Instance Method Details
#dequeue(_job) ⇒ Object
21 22 23 |
# File 'lib/ruby_job/job_store.rb', line 21 def dequeue(_job) raise NotImplementedError end |
#enqueue(_job) ⇒ Object
17 18 19 |
# File 'lib/ruby_job/job_store.rb', line 17 def enqueue(_job) raise NotImplementedError end |
#fetch ⇒ Object
29 30 31 |
# File 'lib/ruby_job/job_store.rb', line 29 def fetch(*) raise NotImplementedError end |
#next_uuid ⇒ Object
37 38 39 |
# File 'lib/ruby_job/job_store.rb', line 37 def next_uuid raise NotImplementedError end |
#pause_at(_time) ⇒ Object
25 26 27 |
# File 'lib/ruby_job/job_store.rb', line 25 def pause_at(_time) raise NotImplementedError end |
#set(**options) ⇒ Object
12 13 14 15 |
# File 'lib/ruby_job/job_store.rb', line 12 def set(**) @options.merge!(**) self end |
#size ⇒ Object
33 34 35 |
# File 'lib/ruby_job/job_store.rb', line 33 def size raise NotImplementedError end |