Class: SidekiqUniqueJobs::Server

Inherits:
Object
  • Object
show all
Defined in:
lib/sidekiq_unique_jobs/server.rb

Overview

The unique sidekiq middleware for the server processor

Author:

Constant Summary collapse

DEATH_HANDLER =

Returns a default death handler for the gem to cleanup dead locks

Returns:

  • (Proc) —

    returns a default death handler for the gem to cleanup dead locks

(lambda do |job, _ex|
  return unless (digest = job["lock_digest"])

  SidekiqUniqueJobs::Digests.new.delete_by_digest(digest)
end).freeze

Class Method Summary collapse

Class Method Details

.configure(config) ⇒ Sidekiq

Configure the server middleware

Returns:

  • (Sidekiq) —

    the sidekiq configuration



21
22
23
24
25
26
27
28
 
# File 'lib/sidekiq_unique_jobs/server.rb', line 21

def self.configure(config)
  config.on(:startup)  { start }
  config.on(:shutdown) { stop }

  return unless config.respond_to?(:death_handlers)

  config.death_handlers << death_handler
end

.death_handler ⇒ lambda

A death handler for dead jobs

Returns:

  • (lambda) 


58
59
60
 
# File 'lib/sidekiq_unique_jobs/server.rb', line 58

def self.death_handler
  DEATH_HANDLER
end

.start ⇒ void

This method returns an undefined value.

Start the sidekiq unique jobs server process



36
37
38
39
40
 
# File 'lib/sidekiq_unique_jobs/server.rb', line 36

def self.start
  SidekiqUniqueJobs::UpdateVersion.call
  SidekiqUniqueJobs::Orphans::Manager.start
  SidekiqUniqueJobs::Orphans::ReaperResurrector.start
end

.stop ⇒ void

This method returns an undefined value.

Stop the sidekiq unique jobs server process



48
49
50
 
# File 'lib/sidekiq_unique_jobs/server.rb', line 48

def self.stop
  SidekiqUniqueJobs::Orphans::Manager.stop
end