mirror of
https://github.com/puppetlabs/vmpooler.git
synced 2026-01-26 01:58:41 -05:00
(POOLER-73) Add spec tests for move_vm_queue
Add spec tests for move_vm_queue
This commit is contained in:
parent
cb4e1400aa
commit
9d8b792c4a
1 changed files with 39 additions and 0 deletions
|
|
@ -11,6 +11,7 @@ describe 'Pool Manager' do
|
||||||
let(:vm) { 'vm1' }
|
let(:vm) { 'vm1' }
|
||||||
let(:timeout) { 5 }
|
let(:timeout) { 5 }
|
||||||
let(:host) { double('host') }
|
let(:host) { double('host') }
|
||||||
|
let(:token) { 'token1234'}
|
||||||
|
|
||||||
subject { Vmpooler::PoolManager.new(config, logger, redis, metrics) }
|
subject { Vmpooler::PoolManager.new(config, logger, redis, metrics) }
|
||||||
|
|
||||||
|
|
@ -458,6 +459,44 @@ EOT
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
describe '#move_vm_queue' do
|
||||||
|
let(:queue_from) { 'pending' }
|
||||||
|
let(:queue_to) { 'completed' }
|
||||||
|
let(:message) { 'message' }
|
||||||
|
|
||||||
|
before do
|
||||||
|
expect(subject).not_to be_nil
|
||||||
|
end
|
||||||
|
|
||||||
|
before(:each) do
|
||||||
|
create_pending_vm(pool, vm, token)
|
||||||
|
end
|
||||||
|
|
||||||
|
it 'VM should be in the "from queue" before the move' do
|
||||||
|
expect(redis.sismember("vmpooler__#{queue_from}__#{pool}",vm))
|
||||||
|
end
|
||||||
|
|
||||||
|
it 'VM should not be in the "from queue" after the move' do
|
||||||
|
subject.move_vm_queue(pool, vm, queue_from, queue_to, message)
|
||||||
|
expect(!redis.sismember("vmpooler__#{queue_from}__#{pool}",vm))
|
||||||
|
end
|
||||||
|
|
||||||
|
it 'VM should not be in the "to queue" before the move' do
|
||||||
|
expect(!redis.sismember("vmpooler__#{queue_to}__#{pool}",vm))
|
||||||
|
end
|
||||||
|
|
||||||
|
it 'VM should be in the "to queue" after the move' do
|
||||||
|
subject.move_vm_queue(pool, vm, queue_from, queue_to, message)
|
||||||
|
expect(redis.sismember("vmpooler__#{queue_to}__#{pool}",vm))
|
||||||
|
end
|
||||||
|
|
||||||
|
it 'should log a message' do
|
||||||
|
allow(logger).to receive(:log).with('d', "[!] [#{pool}] '#{vm}' #{message}")
|
||||||
|
|
||||||
|
subject.move_vm_queue(pool, vm, queue_from, queue_to, message)
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
describe '#move_running_to_completed' do
|
describe '#move_running_to_completed' do
|
||||||
before do
|
before do
|
||||||
expect(subject).not_to be_nil
|
expect(subject).not_to be_nil
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue