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

Add Sidekiq::Process#queues method (#4917)

This commit is contained in:
Matt Duszynski 2021-06-03 10:02:48 -07:00 committed by GitHub
parent ed08a68eb5
commit 02348cdc97
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
3 changed files with 7 additions and 1 deletions

View file

@ -882,6 +882,10 @@ module Sidekiq
self["identity"]
end
def queues
self["queues"]
end
def quiet!
signal("TSTP")
end

View file

@ -540,6 +540,7 @@ describe 'API' do
'key' => identity_string,
'identity' => identity_string,
'started_at' => Time.now.to_f - 15,
'queues' => ['foo', 'bar']
}
time = Time.now.to_f
@ -557,6 +558,7 @@ describe 'API' do
assert_equal 10, data['busy']
assert_equal time, data['beat']
assert_equal 123, data['pid']
assert_equal ['foo', 'bar'], data.queues
data.quiet!
data.stop!
signals_string = "#{odata['key']}-signals"

View file

@ -70,7 +70,7 @@
<% end %>
<br>
<b><%= "#{t('Queues')}: " %></b>
<%= process['queues'] * ", " %>
<%= process.queues.join(", ") %>
</td>
<td><%= relative_time(Time.at(process['started_at'])) %></td>
<td><%= format_memory(process['rss'].to_i) %></td>