Module: Kestrel::Client::StatsHelper
- Included in:
- Kestrel::Client
- Defined in:
- lib/kestrel/client/stats_helper.rb
Constant Summary collapse
- STATS_TIMEOUT =
3
- QUEUE_STAT_NAMES =
%w{items bytes total_items logsize expired_items mem_items mem_bytes age discarded waiters open_transactions}
Instance Method Summary collapse
Instance Method Details
#available_queues ⇒ Object
10 11 12 |
# File 'lib/kestrel/client/stats_helper.rb', line 10 def available_queues stats['queues'].keys.sort end |
#sizeof(queue) ⇒ Object
5 6 7 8 |
# File 'lib/kestrel/client/stats_helper.rb', line 5 def sizeof(queue) stat_info = stat(queue) stat_info ? stat_info['items'] : 0 end |
#stat(queue) ⇒ Object
34 35 36 |
# File 'lib/kestrel/client/stats_helper.rb', line 34 def stat(queue) stats['queues'][queue] end |
#stats ⇒ Object
14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 |
# File 'lib/kestrel/client/stats_helper.rb', line 14 def stats alive, dead = 0, 0 results = servers.map do |server| begin result = stats_for_server(server) alive += 1 result rescue Exception dead += 1 nil end end.compact stats = merge_stats(results) stats['alive_servers'] = alive stats['dead_servers'] = dead stats end |