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
158 159 160 |
# File 'lib/sidekiq/testing.rb', line 158 def [](queue) jobs_by_queue[queue] end |
.clear_all ⇒ Object
185 186 187 188 |
# File 'lib/sidekiq/testing.rb', line 185 def clear_all jobs_by_queue.clear jobs_by_worker.clear end |
.clear_for(queue, klass) ⇒ Object
180 181 182 183 |
# File 'lib/sidekiq/testing.rb', line 180 def clear_for(queue, klass) jobs_by_queue[queue].clear jobs_by_worker[klass].clear end |
.delete_for(jid, queue, klass) ⇒ Object
175 176 177 178 |
# File 'lib/sidekiq/testing.rb', line 175 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
167 168 169 |
# File 'lib/sidekiq/testing.rb', line 167 def jobs_by_queue @jobs_by_queue ||= Hash.new { |hash, key| hash[key] = [] } end |
.jobs_by_worker ⇒ Object
171 172 173 |
# File 'lib/sidekiq/testing.rb', line 171 def jobs_by_worker @jobs_by_worker ||= Hash.new { |hash, key| hash[key] = [] } end |
.push(queue, klass, job) ⇒ Object
162 163 164 165 |
# File 'lib/sidekiq/testing.rb', line 162 def push(queue, klass, job) jobs_by_queue[queue] << job jobs_by_worker[klass] << job end |