Sha256: 145dd4eef7dc6a253ea576ce5a6dc166e1e3ca14971cd8e2521bef6707a4cd05
Contents?: true
Size: 993 Bytes
Versions: 1
Compression:
Stored size: 993 Bytes
Contents
require 'spec_helper' Thread.abort_on_exception = true RSpec.describe Sidekiq::LimitFetch::Global::Monitor do let(:queues) { double dynamic?: false } let(:monitor) { described_class.start! queues, ttl, timeout } let(:ttl) { 1 } let(:queue) { Sidekiq::Queue[name] } let(:name) { 'default' } before :each do monitor end after :each do monitor.kill end context 'old locks' do let(:timeout) { 0.5 } it 'should remove invalidated old locks' do 2.times { queue.acquire } sleep 2*ttl expect(queue.probed).to eq 2 allow(described_class).to receive(:update_heartbeat) sleep 2*ttl expect(queue.probed).to eq 0 end it 'should remove invalid locks' do 2.times { queue.acquire } allow(described_class).to receive(:update_heartbeat) Sidekiq.redis do |it| it.del Sidekiq::LimitFetch::Global::Monitor::PROCESS_SET end sleep 2*ttl expect(queue.probed).to eq 0 end end end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
sidekiq-limit_fetch-2.4.2 | spec/sidekiq/limit_fetch/global/monitor_spec.rb |