module Sidekiq::Haron::Storage
Constants
- DEFAULT_EXPIRY
Protected Instance Methods
clean_for_id(id)
click to toggle source
# File lib/sidekiq/haron/storage.rb, line 24 def clean_for_id(id) Sidekiq.redis do |conn| conn.del(key(id)) end end
read_for_id(id)
click to toggle source
# File lib/sidekiq/haron/storage.rb, line 18 def read_for_id(id) Sidekiq.redis do |conn| conn.hgetall(key(id)) end end
store_for_id(id, data, redis_pool=nil)
click to toggle source
# File lib/sidekiq/haron/storage.rb, line 9 def store_for_id(id, data, redis_pool=nil) redis_connection(redis_pool) do |conn| conn.multi do conn.hmset key(id), *(data.to_a.flatten(1)) conn.expire key(id), DEFAULT_EXPIRY end[0] end end
Private Instance Methods
key(id)
click to toggle source
# File lib/sidekiq/haron/storage.rb, line 44 def key(id) "sidekiq:haron:#{id}" end
redis_connection(redis_pool=nil) { |conn| ... }
click to toggle source
# File lib/sidekiq/haron/storage.rb, line 32 def redis_connection(redis_pool=nil) if redis_pool redis_pool.with do |conn| yield conn end else Sidekiq.redis do |conn| yield conn end end end