class Nexaas::Async::Collector::Storage
Public Instance Methods
get(key)
click to toggle source
# File lib/nexaas/async/collector/storage.rb, line 6 def get(key) Sidekiq.redis_pool.with do |connection| connection.get(namespaced_key(key)) end end
set(key, value, expiration)
click to toggle source
# File lib/nexaas/async/collector/storage.rb, line 12 def set(key, value, expiration) Sidekiq.redis_pool.with do |connection| key = namespaced_key(key) connection.multi do connection.set(key, value) connection.expire(key, expiration) end end end
Private Instance Methods
namespaced_key(key)
click to toggle source
# File lib/nexaas/async/collector/storage.rb, line 24 def namespaced_key(key) "#{redis_namespace}:#{key}" end
redis_namespace()
click to toggle source
# File lib/nexaas/async/collector/storage.rb, line 32 def redis_namespace Nexaas::Async::Collector.redis_namespace end
redis_url()
click to toggle source
# File lib/nexaas/async/collector/storage.rb, line 28 def redis_url Nexaas::Async::Collector.redis_url end