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.1.0"
Superclass = 
if defined?(Sidekiq::JobSet)
  Sidekiq::JobSet
else
  Sidekiq::SortedSet
end

Class Method Summary collapse

Class Method Details

.clear_failures ⇒ Object 



71
72
73
 
# File 'lib/sidekiq/failures.rb', line 71

def self.clear_failures
  FailureSet.new.clear
end

.count ⇒ Object 



75
76
77
 
# File 'lib/sidekiq/failures.rb', line 75

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

.reset_failure_count ⇒ Object 



67
68
69
 
# File 'lib/sidekiq/failures.rb', line 67

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

.reset_failures ⇒ Object 



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

def self.reset_failures
  warn "NOTE: Sidekiq::Failures.reset_failures is deprecated; use Sidekiq::Failures.reset_failure_count instead."

  reset_failure_count
end

.retry_middleware_class ⇒ Object 



79
80
81
82
83
84
85
86
87
 
# File 'lib/sidekiq/failures.rb', line 79

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