Class: SidekiqRobustJob

Inherits:
Object
  • Object
show all
Defined in:
lib/sidekiq_robust_job.rb,
lib/sidekiq_robust_job/model.rb,
lib/sidekiq_robust_job/repository.rb,
lib/sidekiq_robust_job/missed_jobs.rb,
lib/sidekiq_robust_job/configuration.rb,
lib/sidekiq_robust_job/digest_generator.rb,
lib/sidekiq_robust_job/setter_proxy_job.rb,
lib/sidekiq_robust_job/sidekiq_job_manager.rb,
lib/sidekiq_robust_job/uniqueness_strategy.rb,
lib/sidekiq_robust_job/missed_jobs_scheduler.rb,
lib/sidekiq_robust_job/dependencies_container.rb,
lib/sidekiq_robust_job/sidekiq_job_extensions.rb,
lib/sidekiq_robust_job/perform_missed_jobs_job.rb,
lib/sidekiq_robust_job/uniqueness_strategy/base.rb,
lib/sidekiq_robust_job/uniqueness_strategy/no_uniqueness.rb,
lib/sidekiq_robust_job/uniqueness_strategy/until_executed.rb,
lib/sidekiq_robust_job/uniqueness_strategy/until_executing.rb,
lib/sidekiq_robust_job/uniqueness_strategy/while_executing.rb,
lib/sidekiq_robust_job/enqueue_conflict_resolution_strategy.rb,
lib/sidekiq_robust_job/enqueue_conflict_resolution_strategy/base.rb,
lib/sidekiq_robust_job/enqueue_conflict_resolution_strategy/replace.rb,
lib/sidekiq_robust_job/enqueue_conflict_resolution_strategy/drop_self.rb,
lib/sidekiq_robust_job/enqueue_conflict_resolution_strategy/do_nothing.rb

Defined Under Namespace

Modules: Model, SidekiqJobExtensions Classes: Configuration, DependenciesContainer, DigestGenerator, EnqueueConflictResolutionStrategy, MissedJobs, MissedJobsScheduler, PerformMissedJobsJob, Repository, SetterProxyJob, SidekiqJobManager, UniquenessStrategy

Class Method Summary collapse

Class Method Details

.configuration ⇒ Object 



29
30
31
 
# File 'lib/sidekiq_robust_job.rb', line 29

def self.configuration
  @configuration ||= SidekiqRobustJob::Configuration.new
end

.configure {|configuration| ... } ⇒ Object

Yields:



33
34
35
 
# File 'lib/sidekiq_robust_job.rb', line 33

def self.configure
  yield configuration
end

.perform(job_id) ⇒ Object 



53
54
55
 
# File 'lib/sidekiq_robust_job.rb', line 53

def self.perform(job_id)
  sidekiq_job_manager.perform(job_id)
end

.perform_async(job_class, *arguments) ⇒ Object 



37
38
39
 
# File 'lib/sidekiq_robust_job.rb', line 37

def self.perform_async(job_class, *arguments)
  sidekiq_job_manager.perform_async(job_class, *arguments)
end

.perform_at(job_class, interval, *arguments) ⇒ Object 



45
46
47
 
# File 'lib/sidekiq_robust_job.rb', line 45

def self.perform_at(job_class, interval, *arguments)
  sidekiq_job_manager.perform_at(job_class, interval, *arguments)
end

.perform_in(job_class, interval, *arguments) ⇒ Object 



41
42
43
 
# File 'lib/sidekiq_robust_job.rb', line 41

def self.perform_in(job_class, interval, *arguments)
  sidekiq_job_manager.perform_in(job_class, interval, *arguments)
end

.schedule_missed_jobs_handling ⇒ Object 



57
58
59
 
# File 'lib/sidekiq_robust_job.rb', line 57

def self.schedule_missed_jobs_handling
  SidekiqRobustJob::DependenciesContainer["missed_jobs_scheduler"].schedule
end

.set(job_class, options) ⇒ Object 



49
50
51
 
# File 'lib/sidekiq_robust_job.rb', line 49

def self.set(job_class, options)
  sidekiq_job_manager.set(job_class, options)
end