Module: Sidekiq::Queues
- Defined in:
- lib/sidekiq/testing.rb
Class Method Summary collapse
- .[](queue) ⇒ Object
- .clear_all ⇒ Object
- .clear_for(queue, klass) ⇒ Object
- .delete_for(jid, queue, klass) ⇒ Object
- .jobs_by_queue ⇒ Object
- .jobs_by_worker ⇒ Object
- .push(queue, klass, job) ⇒ Object
Class Method Details
.[](queue) ⇒ Object
156 157 158 |
# File 'lib/sidekiq/testing.rb', line 156 def [](queue) jobs_by_queue[queue] end |
.clear_all ⇒ Object
183 184 185 186 |
# File 'lib/sidekiq/testing.rb', line 183 def clear_all jobs_by_queue.clear jobs_by_worker.clear end |
.clear_for(queue, klass) ⇒ Object
178 179 180 181 |
# File 'lib/sidekiq/testing.rb', line 178 def clear_for(queue, klass) jobs_by_queue[queue].clear jobs_by_worker[klass].clear end |
.delete_for(jid, queue, klass) ⇒ Object
173 174 175 176 |
# File 'lib/sidekiq/testing.rb', line 173 def delete_for(jid, queue, klass) jobs_by_queue[queue.to_s].delete_if { |job| job["jid"] == jid } jobs_by_worker[klass].delete_if { |job| job["jid"] == jid } end |
.jobs_by_queue ⇒ Object
165 166 167 |
# File 'lib/sidekiq/testing.rb', line 165 def jobs_by_queue @jobs_by_queue ||= Hash.new { |hash, key| hash[key] = [] } end |
.jobs_by_worker ⇒ Object
169 170 171 |
# File 'lib/sidekiq/testing.rb', line 169 def jobs_by_worker @jobs_by_worker ||= Hash.new { |hash, key| hash[key] = [] } end |
.push(queue, klass, job) ⇒ Object
160 161 162 163 |
# File 'lib/sidekiq/testing.rb', line 160 def push(queue, klass, job) jobs_by_queue[queue] << job jobs_by_worker[klass] << job end |