Searched refs:ConcurrencyBalancer (Results 1 - 4 of 4) sorted by relevance

/ontohub/spec/lib/
H A Dconcurrency_balancer_spec.rb3 describe ConcurrencyBalancer do
5 let(:balancer) { ConcurrencyBalancer.new }
6 let(:redis) { ConcurrencyBalancer::RedisWrapper.new }
9 redis.del ConcurrencyBalancer::REDIS_KEY
10 redis.del ConcurrencyBalancer::SEQUENTIAL_LOCK_KEY
22 redis.sadd ConcurrencyBalancer::REDIS_KEY, 'iri'
24 to raise_error(ConcurrencyBalancer::AlreadyProcessingError)
30 redis.sadd ConcurrencyBalancer::REDIS_KEY, 'iri'
39 to raise_error(ConcurrencyBalancer::UnmarkedProcessingError)
45 redis.sadd ConcurrencyBalancer
[all...]
/ontohub/app/viewhelpers/
H A Dstatus_overview_viewhelper.rb9 redis.smembers(ConcurrencyBalancer::REDIS_KEY).size
H A Dstatus_ontology_viewhelper.rb41 redis.smembers ConcurrencyBalancer::REDIS_KEY
/ontohub/lib/
H A Dconcurrency_balancer.rb7 class ConcurrencyBalancer class

Completed in 25 milliseconds