lib/ldclient-rb/redis_store.rb in ldclient-rb-3.0.1 vs lib/ldclient-rb/redis_store.rb in ldclient-rb-3.0.2
- old
+ new
@@ -92,28 +92,28 @@
end
def get(kind, key)
f = @cache[cache_key(kind, key)]
if f.nil?
- @logger.debug("RedisFeatureStore: no cache hit for #{key} in '#{kind[:namespace]}', requesting from Redis")
+ @logger.debug { "RedisFeatureStore: no cache hit for #{key} in '#{kind[:namespace]}', requesting from Redis" }
f = with_connection do |redis|
begin
get_redis(kind, redis, key.to_sym)
rescue => e
- @logger.error("RedisFeatureStore: could not retrieve #{key} from Redis in '#{kind[:namespace]}', with error: #{e}")
+ @logger.error { "RedisFeatureStore: could not retrieve #{key} from Redis in '#{kind[:namespace]}', with error: #{e}" }
nil
end
end
if !f.nil?
put_cache(kind, key, f)
end
end
if f.nil?
- @logger.debug("RedisFeatureStore: #{key} not found in '#{kind[:namespace]}'")
+ @logger.debug { "RedisFeatureStore: #{key} not found in '#{kind[:namespace]}'" }
nil
elsif f[:deleted]
- @logger.debug("RedisFeatureStore: #{key} was deleted in '#{kind[:namespace]}', returning nil")
+ @logger.debug { "RedisFeatureStore: #{key} was deleted in '#{kind[:namespace]}', returning nil" }
nil
else
f
end
end
@@ -122,11 +122,11 @@
fs = {}
with_connection do |redis|
begin
hashfs = redis.hgetall(items_key(kind))
rescue => e
- @logger.error("RedisFeatureStore: could not retrieve all '#{kind[:namespace]}' items from Redis with error: #{e}; returning none")
+ @logger.error { "RedisFeatureStore: could not retrieve all '#{kind[:namespace]}' items from Redis with error: #{e}; returning none" }
hashfs = {}
end
hashfs.each do |k, jsonItem|
f = JSON.parse(jsonItem, symbolize_names: true)
if !f[:deleted]
@@ -167,11 +167,11 @@
items.each { |k, v| put_redis_and_cache(kind, multi, k, v) }
end
end
end
@inited.set(true)
- @logger.info("RedisFeatureStore: initialized with #{count} items")
+ @logger.info { "RedisFeatureStore: initialized with #{count} items" }
end
def upsert(kind, item)
with_connection do |redis|
redis.watch(items_key(kind)) do
@@ -217,11 +217,11 @@
def get_redis(kind, redis, key)
begin
json_item = redis.hget(items_key(kind), key)
JSON.parse(json_item, symbolize_names: true) if json_item
rescue => e
- @logger.error("RedisFeatureStore: could not retrieve #{key} from Redis, error: #{e}")
+ @logger.error { "RedisFeatureStore: could not retrieve #{key} from Redis, error: #{e}" }
nil
end
end
def put_cache(kind, key, value)
@@ -230,10 +230,10 @@
def put_redis_and_cache(kind, redis, key, item)
begin
redis.hset(items_key(kind), key, item.to_json)
rescue => e
- @logger.error("RedisFeatureStore: could not store #{key} in Redis, error: #{e}")
+ @logger.error { "RedisFeatureStore: could not store #{key} in Redis, error: #{e}" }
end
put_cache(kind, key.to_sym, item)
end
def query_inited