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