class SidekiqRobustJob::DependenciesContainer

Public Class Methods

[](method_name) click to toggle source
# File lib/sidekiq_robust_job/dependencies_container.rb, line 3
def self.[](method_name)
  public_send(method_name)
end
digest_generator() click to toggle source
# File lib/sidekiq_robust_job/dependencies_container.rb, line 32
def self.digest_generator
  SidekiqRobustJob::DigestGenerator.new(
    backend: SidekiqRobustJob.configuration.digest_generator_backend
  )
end
enqueue_conflict_resolution_resolver() click to toggle source
# File lib/sidekiq_robust_job/dependencies_container.rb, line 38
def self.enqueue_conflict_resolution_resolver
  SidekiqRobustJob::EnqueueConflictResolutionStrategy.new(
    jobs_repository: SidekiqRobustJob::DependenciesContainer["jobs_repository"],
    clock: SidekiqRobustJob.configuration.clock
  )
end
jobs_repository() click to toggle source
# File lib/sidekiq_robust_job/dependencies_container.rb, line 16
def self.jobs_repository
  SidekiqRobustJob::Repository.new(
    jobs_database: SidekiqRobustJob.configuration.sidekiq_job_model,
    clock: SidekiqRobustJob.configuration.clock
  )
end
missed_jobs() click to toggle source
# File lib/sidekiq_robust_job/dependencies_container.rb, line 49
def self.missed_jobs
  SidekiqRobustJob::MissedJobs.new(
    jobs_repository: SidekiqRobustJob::DependenciesContainer["jobs_repository"],
    missed_job_policy: SidekiqRobustJob.configuration.missed_job_policy
  )
end
missed_jobs_scheduler() click to toggle source
# File lib/sidekiq_robust_job/dependencies_container.rb, line 56
def self.missed_jobs_scheduler
  SidekiqRobustJob::MissedJobsScheduler.new(
    cron: SidekiqRobustJob.configuration.missed_job_cron,
    scheduled_jobs_repository: Sidekiq::Cron::Job,
    job_class: SidekiqRobustJob::PerformMissedJobsJob
  )
end
setter_proxy_job() click to toggle source
# File lib/sidekiq_robust_job/dependencies_container.rb, line 45
def self.setter_proxy_job
  SidekiqRobustJob::SetterProxyJob.new
end
sidekiq_job_manager() click to toggle source
# File lib/sidekiq_robust_job/dependencies_container.rb, line 7
def self.sidekiq_job_manager
  SidekiqRobustJob::SidekiqJobManager.new(
    jobs_repository: SidekiqRobustJob::DependenciesContainer["jobs_repository"],
    clock: SidekiqRobustJob.configuration.clock,
    digest_generator: SidekiqRobustJob::DependenciesContainer["digest_generator"],
    memory_monitor: SidekiqRobustJob.configuration.memory_monitor
  )
end
uniqueness_strategy_resolver() click to toggle source
# File lib/sidekiq_robust_job/dependencies_container.rb, line 23
def self.uniqueness_strategy_resolver
  SidekiqRobustJob::UniquenessStrategy.new(
    locker: SidekiqRobustJob.configuration.locker,
    lock_ttl_proc: SidekiqRobustJob.configuration.lock_ttl_proc,
    jobs_repository: SidekiqRobustJob::DependenciesContainer["jobs_repository"],
    memory_monitor: SidekiqRobustJob.configuration.memory_monitor
  )
end