37 lines
911 B
Ruby
37 lines
911 B
Ruby
|
# frozen_string_literal: true
|
||
|
|
|
||
|
|
require 'test_helper'
|
||
|
|
require 'concurrent/set'
|
||
|
|
|
||
|
|
class ClusterTest < ActiveSupport::TestCase
|
||
|
|
test 'Cluster has instance record of all cluster' do
|
||
|
|
assert_equal 0, Cluster.list.size, 'starts off empty'
|
||
|
|
Cluster.new('foo')
|
||
|
|
Cluster.new('bar')
|
||
|
|
assert_equal 2, Cluster.list.size, 'Increases as more are added'
|
||
|
|
end
|
||
|
|
|
||
|
|
test 'cluster are addressable by the UUID' do
|
||
|
|
Cluster.new('bar')
|
||
|
|
cluster = Cluster.new('foo')
|
||
|
|
assert_equal cluster, Cluster.get(cluster.uuid)
|
||
|
|
end
|
||
|
|
|
||
|
|
test 'works' do
|
||
|
|
cluster = Cluster.new('foo')
|
||
|
|
cluster.increment
|
||
|
|
assert_equal 1, cluster.count
|
||
|
|
cluster.decrement
|
||
|
|
assert_equal 0, cluster.count
|
||
|
|
end
|
||
|
|
|
||
|
|
test 'is thread safe' do
|
||
|
|
cluster = Cluster.new('foo')
|
||
|
|
threads = []
|
||
|
|
(1..500).each { |_x| threads << Thread.new { cluster.increment } }
|
||
|
|
threads.each(&:join)
|
||
|
|
|
||
|
|
assert_equal 500, cluster.count
|
||
|
|
end
|
||
|
|
end
|