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.4.0"

Class Method Summary collapse

Class Method Details

.clear_all ⇒ Object 



27
28
29
 
# File 'lib/sidekiq/expected_failures.rb', line 27

def self.clear_all
  clear(dates.keys)
end

.clear_counters ⇒ Object 



36
37
38
 
# File 'lib/sidekiq/expected_failures.rb', line 36

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

.clear_old(days_ago = 1) ⇒ Object 



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

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 



23
24
25
 
# File 'lib/sidekiq/expected_failures.rb', line 23

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

.dates ⇒ Object 



15
16
17
18
19
20
21
 
# File 'lib/sidekiq/expected_failures.rb', line 15

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