Sidekiq API Reference

sidekiq_api_reference.rb

Sidekiq.redis { |conn| conn.flushdb } # clear everything

Sidekiq::Queue.all # get all queues
Sidekiq::Queue.new # get the "default" queue
Sidekiq::Queue.new("mailer") # get the "mailer" queue
Sidekiq::Queue.new.clear # deletes all jobs in a queue, by removing the queue
Sidekiq::Queue.all.each(&:clear) # deletes all jobs in all queues

ss = Sidekiq::ScheduledSet.new
ss.size
ss.clear
jobs = ss.select { |job| job.klass == 'SomeWorker' }
jobs.each(&:delete)

Sidekiq::RetrySet.new
Sidekiq::DeadSet.new
Sidekiq::ProcessSet.new # running processes

Sidekiq::Stats.new.reset # reset statistics