Class: SidekiqRobustJob::MissedJobs

Inherits:

Object

• Object
• SidekiqRobustJob::MissedJobs

Extended by:

Forwardable

Includes:

Enumerable

Defined in:

lib/sidekiq_robust_job/missed_jobs.rb

Instance Method Summary

• #all ⇒ Object
• #initialize(jobs_repository:, missed_job_policy:) ⇒ MissedJobs constructor

  A new instance of MissedJobs.

• #invoke ⇒ Object

Constructor Details

#initialize(jobs_repository:, missed_job_policy:) ⇒ MissedJobs

Returns a new instance of MissedJobs.

# File 'lib/sidekiq_robust_job/missed_jobs.rb', line 13

def initialize(jobs_repository:, missed_job_policy:)
  @jobs_repository = jobs_repository
  @missed_job_policy = missed_job_policy
end

Instance Method Details

#all ⇒ Object

# File 'lib/sidekiq_robust_job/missed_jobs.rb', line 18

def all
  @all ||= jobs_repository.missed_jobs(missed_job_policy: missed_job_policy)
end

#invoke ⇒ Object

# File 'lib/sidekiq_robust_job/missed_jobs.rb', line 22

def invoke
  each(&:reschedule)
end