Skip to content

Commit

Permalink
Protect private methods
Browse files Browse the repository at this point in the history
  • Loading branch information
ismaelga committed Jan 16, 2015
1 parent 8f36e26 commit 2207226
Showing 1 changed file with 45 additions and 43 deletions.
88 changes: 45 additions & 43 deletions lib/sidekiq/api.rb
Expand Up @@ -23,6 +23,51 @@ def dead_size
stat 'dead_size'
end

def fetch_stats!
stats
end

def reset(*stats)
all = %w(failed processed)
stats = stats.empty? ? all : all & stats.flatten.compact.map(&:to_s)

mset_args = []
stats.each do |stat|
mset_args << "stat:#{stat}"
mset_args << 0
end
Sidekiq.redis do |conn|
conn.mset(*mset_args)
end
end

def queues
Sidekiq.redis do |conn|
queues = conn.smembers('queues'.freeze)

lengths = conn.pipelined do
queues.each do |queue|
conn.llen("queue:#{queue}")
end
end

i = 0
array_of_arrays = queues.inject({}) do |memo, queue|
memo[queue] = lengths[i]
i += 1
memo
end.sort_by { |_, size| size }

Hash[array_of_arrays.reverse]
end
end

def enqueued
queues.values.inject(&:+) || 0
end

private

def stats(*only)
all = %w(processed failed queues enqueued scheduled_size retry_size dead_size)
metrics = only.any? ? only : all
Expand All @@ -38,10 +83,6 @@ def stats(*only)
end
end

def fetch_stats!
stats
end

def stat(s)
stats(s)[s]
end
Expand Down Expand Up @@ -73,45 +114,6 @@ def load_stats(*metrics)
loaded_stats
end

def reset(*stats)
all = %w(failed processed)
stats = stats.empty? ? all : all & stats.flatten.compact.map(&:to_s)

mset_args = []
stats.each do |stat|
mset_args << "stat:#{stat}"
mset_args << 0
end
Sidekiq.redis do |conn|
conn.mset(*mset_args)
end
end

def queues
Sidekiq.redis do |conn|
queues = conn.smembers('queues'.freeze)

lengths = conn.pipelined do
queues.each do |queue|
conn.llen("queue:#{queue}")
end
end

i = 0
array_of_arrays = queues.inject({}) do |memo, queue|
memo[queue] = lengths[i]
i += 1
memo
end.sort_by { |_, size| size }

Hash[array_of_arrays.reverse]
end
end

def enqueued
queues.values.inject(&:+) || 0
end

class History
def initialize(days_previous, start_date = nil)
@days_previous = days_previous
Expand Down

0 comments on commit 2207226

Please sign in to comment.