Module: Sidekiq::ExpectedFailures

Defined in:
lib/sidekiq/expected_failures.rb,
lib/sidekiq/expected_failures/web.rb,
lib/sidekiq/expected_failures/version.rb,
lib/sidekiq/expected_failures/middleware.rb

Defined Under Namespace

Modules: Web Classes: Middleware

Constant Summary collapse

VERSION = 
"0.2.4"

Class Method Summary collapse

Class Method Details

.clear_all ⇒ Object 



34
35
36
 
# File 'lib/sidekiq/expected_failures.rb', line 34

def self.clear_all
  clear(dates.keys)
end

.clear_counters ⇒ Object 



43
44
45
 
# File 'lib/sidekiq/expected_failures.rb', line 43

def self.clear_counters
  Sidekiq.redis { |r| r.del("expected:count") }
end

.clear_old(days_ago = 1) ⇒ Object 



38
39
40
41
 
# File 'lib/sidekiq/expected_failures.rb', line 38

def self.clear_old(days_ago = 1)
  range = dates.keys.delete_if { |d| Date.parse(d) > Date.today.prev_day(days_ago) }
  clear(range)
end

.counters ⇒ Object 



30
31
32
 
# File 'lib/sidekiq/expected_failures.rb', line 30

def self.counters
  Sidekiq.redis { |r| r.hgetall("expected:count") }
end

.dates ⇒ Object 



22
23
24
25
26
27
28
 
# File 'lib/sidekiq/expected_failures.rb', line 22

def self.dates
  Sidekiq.redis do |c|
    c.smembers "expected:dates"
  end.sort.reverse.each_with_object({}) do |d, hash|
    hash[d] = Sidekiq.redis { |c| c.llen("expected:#{d}") }
  end
end