Skip to content

Commit

Permalink
Add clear_failures method (#145)
Browse files Browse the repository at this point in the history
  • Loading branch information
adamzapasnik authored Oct 4, 2022
1 parent 0d4ba77 commit 2b30cb1
Show file tree
Hide file tree
Showing 2 changed files with 18 additions and 3 deletions.
11 changes: 8 additions & 3 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -127,13 +127,18 @@ influenced by `failures_max_count`.
Sidekiq::Failures.count
```

### Reset Failures
### Reset and clear Failures

Gives a convenient way of reseting Sidekiq Failure stored failed jobs programmatically.
Takes an options hash and if the `counter` key is present also resets Sidekiq own failed stats.

```ruby
Sidekiq::Failures.reset_failures
Sidekiq::Failures.clear_failures
```

To reset Sidekiq own failed *stats*.

```ruby
Sidekiq::Failures.reset_failure_count
```

## Dependencies
Expand Down
10 changes: 10 additions & 0 deletions lib/sidekiq/failures.rb
Original file line number Diff line number Diff line change
Expand Up @@ -59,9 +59,19 @@ module Failures
LIST_KEY = :failed

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

reset_failure_count
end

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

def self.clear_failures
FailureSet.new.clear
end

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

0 comments on commit 2b30cb1

Please sign in to comment.