Module: Sidekiq::Failures

Defined in:
lib/sidekiq/failures.rb,
lib/sidekiq/failures/version.rb,
lib/sidekiq/failures/middleware.rb,
lib/sidekiq/failures/failure_set.rb,
lib/sidekiq/failures/web_extension.rb

Defined Under Namespace

Modules: WebExtension Classes: FailureSet, Middleware

Constant Summary collapse

LIST_KEY = 
:failed
VERSION = 
"1.0.4"
Superclass = 
if defined?(Sidekiq::JobSet)
  Sidekiq::JobSet
else
  Sidekiq::SortedSet
end

Class Method Summary collapse

Class Method Details

.count ⇒ Object 



65
66
67
 
# File 'lib/sidekiq/failures.rb', line 65

def self.count
  Sidekiq.redis {|r| r.zcard(LIST_KEY) }
end

.reset_failures ⇒ Object 



61
62
63
 
# File 'lib/sidekiq/failures.rb', line 61

def self.reset_failures
  Sidekiq.redis { |c| c.set("stat:failed", 0) }
end

.retry_middleware_class ⇒ Object 



69
70
71
72
73
74
75
76
77
 
# File 'lib/sidekiq/failures.rb', line 69

def self.retry_middleware_class
  if Gem::Version.new(Sidekiq::VERSION) >= Gem::Version.new('5.0.0')
    require 'sidekiq/job_retry'
    Sidekiq::JobRetry
  else
    require 'sidekiq/middleware/server/retry_jobs'
    Sidekiq::Middleware::Server::RetryJobs
  end
end