Sha256: 5dbf8ae736a4aefa8b714a0a04e8d9afdc96bb5301d46e524167746974f46d0b
Contents?: true
Size: 1.66 KB
Versions: 12
Compression:
Stored size: 1.66 KB
Contents
require 'dalli-elasticache'
require 'alephant/logger'
module Alephant
module Broker
module Cache
class Client
include Logger
DEFAULT_TTL = 2592000
def initialize
unless config_endpoint.nil?
@@elasticache ||= ::Dalli::ElastiCache.new(config_endpoint, { :expires_in => ttl })
@@client ||= @@elasticache.client
else
logger.debug "Broker::Cache::Client#initialize: No config endpoint, NullClient used"
logger.metric "NoConfigEndpoint"
@@client = NullClient.new
end
end
def get(key, &block)
begin
versioned_key = versioned key
result = @@client.get versioned_key
logger.info "Broker::Cache::Client#get key: #{versioned_key} - #{result ? 'hit' : 'miss'}"
logger.metric "GetKeyMiss" unless result
result ? result : set(key, block.call)
rescue StandardError => e
block.call if block_given?
end
end
def set(key, value, ttl = nil)
value.tap { |o| @@client.set(versioned(key), o, ttl) }
end
private
def config_endpoint
Broker.config['elasticache_config_endpoint']
end
def ttl
Broker.config['elasticache_ttl'] || DEFAULT_TTL
end
def versioned(key)
[key, cache_version].compact.join('_')
end
def cache_version
Broker.config['elasticache_cache_version']
end
end
class NullClient
def get(key); end
def set(key, value, ttl = nil)
value
end
end
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems