Module: Kestrel::Client::StatsHelper

Included in:
Kestrel::Client
Defined in:
lib/kestrel/client/stats_helper.rb

Constant Summary collapse

QUEUE_STAT_NAMES =
%w{items bytes total_items logsize expired_items mem_items mem_bytes age discarded}

Instance Method Summary collapse

Instance Method Details

#available_queuesObject



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



18
19
20
# File 'lib/kestrel/client/stats_helper.rb', line 18

def stat(queue)
  stats['queues'][queue]
end

#statsObject



14
15
16
# File 'lib/kestrel/client/stats_helper.rb', line 14

def stats
  merge_stats(servers.map { |server| stats_for_server(server) })
end