Class: AtomicSidekiq::DeadJobCollector
- Inherits:
-
Object
- Object
- AtomicSidekiq::DeadJobCollector
- Defined in:
- lib/atomic_sidekiq/dead_job_collector.rb
Class Method Summary collapse
Instance Method Summary collapse
- #collect!(skip_recovery: false) ⇒ Object
-
#initialize(queue, in_flight_keymaker:) ⇒ DeadJobCollector
constructor
A new instance of DeadJobCollector.
Constructor Details
#initialize(queue, in_flight_keymaker:) ⇒ DeadJobCollector
Returns a new instance of DeadJobCollector.
12 13 14 15 16 17 |
# File 'lib/atomic_sidekiq/dead_job_collector.rb', line 12 def initialize(queue, in_flight_keymaker:) @recovered_stats = RecoveredStats.new @queue = queue @in_flight_keymaker = in_flight_keymaker @expire_op = AtomicOperation::Expire.new end |
Class Method Details
.collect!(queues, in_flight_keymaker:, skip_recovery_queues: []) ⇒ Object
4 5 6 7 8 9 |
# File 'lib/atomic_sidekiq/dead_job_collector.rb', line 4 def collect!(queues, in_flight_keymaker:, skip_recovery_queues: []) queues.each do |q| new(q, in_flight_keymaker: in_flight_keymaker) .collect!(skip_recovery: skip_recovery_queues.include?(q)) end end |
Instance Method Details
#collect!(skip_recovery: false) ⇒ Object
19 20 21 |
# File 'lib/atomic_sidekiq/dead_job_collector.rb', line 19 def collect!(skip_recovery: false) each_keys { |job_key| expire!(job_key, skip_recovery: skip_recovery) } end |