Sha256: 049dcebfedd51cc0005bc1ecfb382544572d674dd2df551cbcf5d00ab387aa39
Contents?: true
Size: 1.33 KB
Versions: 12
Compression:
Stored size: 1.33 KB
Contents
module Looksist
class RedisService
attr_accessor :client, :buffer_size, :cache
class << self
private :new
def instance
@this ||= new
@this.buffer_size = 50000
yield @this if block_given?
@this.cache = SafeLruCache.new(@this.buffer_size)
@this
end
end
def method_missing(name, *args, &block)
if name.to_s.ends_with?('_for')
entity = name.to_s.gsub('_for', '')
first_arg = args.first
first_arg.is_a?(Array) ? find_all(entity, first_arg) : find(entity, first_arg)
else
super(name, args)
end
end
def flush_cache!
@cache.clear
end
private
def find_all(entity, ids)
raise 'Buffer overflow! Increase buffer size' if ids.length > @buffer_size
keys = ids.collect { |id| redis_key(entity, id) }
missed_keys = (keys - @cache.keys).uniq
unless missed_keys.empty?
values = @client.mget *missed_keys
@cache.merge!(Hash[*missed_keys.zip(values).flatten])
end
@cache.mslice(keys)
end
def find(entity, id)
key = redis_key(entity, id)
fetch(key) do
@client.get(key)
end
end
def fetch(key, &block)
@cache[key] ||= block.call
end
def redis_key(entity, id)
"#{entity.pluralize}/#{id}"
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems