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

Remove deprecated Sidekiq.size

This commit is contained in:
Mike Perham 2013-03-26 21:16:42 -07:00
parent b0def215e1
commit d297f1fefc
2 changed files with 0 additions and 59 deletions

View file

@ -114,16 +114,4 @@ module Sidekiq
self.options[:poll_interval] = interval
end
##
# deprecated
def self.size(*queues)
return Sidekiq::Stats.new.enqueued if queues.empty?
Sidekiq.redis { |conn|
conn.multi {
queues.map { |q| conn.llen("queue:#{q}") }
}
}.inject(0) { |memo, count| memo + count }
end
end

View file

@ -1,47 +0,0 @@
require 'helper'
require 'sidekiq'
require 'sidekiq/processor'
class TestStats < MiniTest::Unit::TestCase
describe 'with redis' do
before do
@redis = Sidekiq.redis = REDIS
Sidekiq.redis {|c| c.flushdb }
end
class DumbWorker
include Sidekiq::Worker
sidekiq_options :queue => 'dumbq'
def perform(arg)
raise 'bang' if arg == nil
end
end
describe "info counts" do
before do
@redis.with do |conn|
conn.rpush 'queue:foo', '{}'
conn.sadd 'queues', 'foo'
3.times { conn.rpush 'queue:bar', '{}' }
conn.sadd 'queues', 'bar'
2.times { conn.rpush 'queue:baz', '{}' }
conn.sadd 'queues', 'baz'
end
end
describe "size" do
it "returns size of queues" do
assert_equal 0, Sidekiq.size("foox")
assert_equal 1, Sidekiq.size(:foo)
assert_equal 1, Sidekiq.size("foo")
assert_equal 4, Sidekiq.size("foo", "bar")
assert_equal 6, Sidekiq.size
end
end
end
end
end