class SidekiqRobustJob::MissedJobs

Attributes

jobs_repository[R]
missed_job_policy[R]

Public Class Methods

new(jobs_repository:, missed_job_policy:) click to toggle source
# 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

Public Instance Methods

all() click to toggle source
# 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() click to toggle source
# File lib/sidekiq_robust_job/missed_jobs.rb, line 22
def invoke
  each(&:reschedule)
end