Contents

require "spec_helper"

describe Sidekiq::Throttler::Storage::Redis do
  let(:storage) { described_class.instance }

  before(:each) do
    @sidekiq = double()
    Sidekiq.stub(:redis).and_yield(@sidekiq)
  end

  describe "#prune" do
    it "pops the last item off the list if it's lower than the cutoff" do
      @sidekiq.stub(:lindex).and_return(100, nil)
      @sidekiq.should_receive(:rpop).with("throttled:fake").and_return(100)
      storage.prune("fake", 200)
    end

    it "leaves the last item on the list if it's higher than the cutoff" do
      @sidekiq.stub(:lindex).and_return(200, nil)
      @sidekiq.should_not_receive(:rpop)
      storage.prune("fake", 100)
    end

    context "when another job has concurrently removed a timestamp" do

      before(:each) do
        @sidekiq.stub(:lindex) { 100 }
        @sidekiq.stub(:rpop)   { 200 }
      end

      it "pushes the value back onto the list" do
        @sidekiq.should_receive(:rpush).with("throttled:fake", 200)
        storage.prune("fake", 1000)
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
sidekiq-throttler-0.4.0	spec/sidekiq/throttler/storage/redis_spec.rb
sidekiq-throttler-0.3.1	spec/sidekiq/throttler/storage/redis_spec.rb
sidekiq-throttler-0.3.0	spec/sidekiq/throttler/storage/redis_spec.rb