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