kotovalexarian-likes-github/mperham--sidekiq
1
0
Fork 0
mirror of https://github.com/mperham/sidekiq.git synced 2022-11-09 13:52:34 -05:00
Code Releases Activity

Minor API updates for the blog post

Browse source
This commit is contained in:
Mike Perham 2021-04-19 16:19:45 -07:00
parent e0f7d2d95f
commit 53999adc2c
1 changed files with 13 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

21
lib/sidekiq/api.rb
View file

@ -826,9 +826,10 @@ module Sidekiq
sum { |x| x["concurrency"] } sum { |x| x["concurrency"] }
end end
def total_rss def total_rss_in_kb
sum { |x| x["rss"] || 0 } sum { |x| x["rss"] || 0 }
end end
alias_method :total_rss, :total_rss_in_kb
# Returns the identity of the current cluster leader or "" if no leader. # Returns the identity of the current cluster leader or "" if no leader.
# This is a Sidekiq Enterprise feature, will always return "" in Sidekiq # This is a Sidekiq Enterprise feature, will always return "" in Sidekiq
@ -909,8 +910,8 @@ module Sidekiq
end end
## ##
# A worker is a thread that is currently processing a job. # The WorkSet is stores the work being done by this Sidekiq cluster.
# Programmatic access to the current active worker set. # It tracks the process and thread working on each job.
# #
# WARNING WARNING WARNING # WARNING WARNING WARNING
# #
@ -918,17 +919,17 @@ module Sidekiq
# If you call #size => 5 and then expect #each to be # If you call #size => 5 and then expect #each to be
# called 5 times, you're going to have a bad time. # called 5 times, you're going to have a bad time.
# #
# workers = Sidekiq::Workers.new # works = Sidekiq::WorkSet.new
# workers.size => 2 # works.size => 2
# workers.each do |process_id, thread_id, work| # works.each do |process_id, thread_id, work|
# # process_id is a unique identifier per Sidekiq process # # process_id is a unique identifier per Sidekiq process
# # thread_id is a unique identifier per thread # # thread_id is a unique identifier per thread
# # work is a Hash which looks like: # # work is a Hash which looks like:
# # { 'queue' => name, 'run_at' => timestamp, 'payload' => msg } # # { 'queue' => name, 'run_at' => timestamp, 'payload' => job_hash }
# # run_at is an epoch Integer. # # run_at is an epoch Integer.
# end # end
# #
class Workers class WorkSet
include Enumerable include Enumerable
def each(&block) def each(&block)
@ -975,4 +976,8 @@ module Sidekiq
end end
end end
end end
# Since "worker" is a nebulous term, we've deprecated the use of this class name.
# Is "worker" a process, a type of job, a thread? Undefined!
# WorkSet better describes the data.
Workers = WorkSet
end end