Skip to content

Instantly share code, notes, and snippets.

@fengshuo

fengshuo/sidekiq_monitoring

Forked from ngsmrk/sidekiq_monitoring
Created July 16, 2019 19:55
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save fengshuo/2c35d357b8a11472d8aa7038e36a57b5 to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save fengshuo/2c35d357b8a11472d8aa7038e36a57b5 to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. @ngsmrk ngsmrk created this gist Aug 11, 2014.
    21 changes: 21 additions & 0 deletions sidekiq_monitoring
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,21 @@
    stats = Sidekiq::Stats.new

    stats.queues

    stats.enqueued

    stats.processed

    stats.failed

    scheduled_queue = Sidekiq::ScheduledSet.new

    retry_queue = Sidekiq::RetrySet.new

    default_queue = Sidekiq::Queue.new("default")

    default_queue.each do | job |
    class_arg = job.args[0].split('-').select { | arg | arg.match(' !ruby/class') }[0]

    p class_arg.split[1].gsub '\'', '' unless class_arg.nil?
    end