Searched refs:redis (Results 1 - 10 of 10) sorted by relevance
| /ontohub/features/support/ |
| H A D | hooks.rb | 2 redis = WrappingRedis::RedisWrapper.new
3 redis.del redis.keys if redis.keys.any?
|
| /ontohub/lib/ |
| H A D | wrapping_redis.rb | 3 # gets and reuses the Sidekiq-redis connection
4 def redis method in class:WrappingRedis
11 Sidekiq.redis { |redis| redis.send(name, *args, &block) }
|
| H A D | concurrency_balancer.rb | 2 # It uses redis to create an atomic global store
24 successful = redis.sadd REDIS_KEY, iri
32 successful = redis.srem REDIS_KEY, iri
39 successful = redis.srem REDIS_KEY, iri
|
| H A D | semaphore.rb | 15 "#{Settings.redis.namespace}:#{self.to_s.downcase}".freeze
62 redis: redis(SEMAPHORES_NAMESPACE))
65 def redis(sema_namespace) method in class:Semaphore
66 Ontohub.redis(namespace: sema_namespace)
|
| /ontohub/config/initializers/ |
| H A D | sidekiq.rb | 3 config.redis = Ontohub::RedisConnection.new.pool.
4 with_namespace("#{Settings.redis.namespace}:sidekiq")
8 config.redis = Ontohub::RedisConnection.new.pool.
9 with_namespace("#{Settings.redis.namespace}:sidekiq")
|
| H A D | redis_pool.rb | 2 # http://ixti.net/development/ruby/2014/03/26/share-sidekiq-s-redis-pool-with-other-part-of-your-app.html
4 require 'redis/namespace'
22 return ::Redis::Namespace.new(namespace, redis: conn)
47 url: ::Settings.redis.url,
62 def self.redis(*args, namespace: nil, &block) singleton method in class:Ontohub
|
| /ontohub/spec/lib/ |
| H A D | concurrency_balancer_spec.rb | 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'
30 redis.sadd ConcurrencyBalancer::REDIS_KEY, 'iri'
45 redis.sadd ConcurrencyBalancer::REDIS_KEY, 'iri'
53 redis.sadd ConcurrencyBalancer::REDIS_KEY, 'iri'
59 redis.sadd ConcurrencyBalancer::REDIS_KEY, 'iri'
61 expect(redis.sismember ConcurrencyBalancer::REDIS_KEY, 'iri').
74 expect(redis
[all...] |
| /ontohub/app/viewhelpers/ |
| H A D | status_overview_viewhelper.rb | 9 redis.smembers(ConcurrencyBalancer::REDIS_KEY).size
|
| H A D | status_ontology_viewhelper.rb | 41 redis.smembers ConcurrencyBalancer::REDIS_KEY
|
| /ontohub/spec/ |
| H A D | spec_helper.rb | 78 redis = WrappingRedis::RedisWrapper.new
79 redis.del redis.keys if redis.keys.any?
|
Completed in 13 milliseconds