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