Sha256: 07a396641d8de18b6c007bc08aa46c69db979696de030655fef2e3d491fe1c0b

Contents?: true

Size: 1.69 KB

Versions: 6

Compression:

Stored size: 1.69 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, &block)
          yield
        end

        def set(key, value, ttl = nil)
          value
        end
      end
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version Path
alephant-broker-3.13.0 lib/alephant/broker/cache.rb
alephant-broker-3.12.0 lib/alephant/broker/cache.rb
alephant-broker-3.11.0 lib/alephant/broker/cache.rb
alephant-broker-3.10.2 lib/alephant/broker/cache.rb
alephant-broker-3.10.1 lib/alephant/broker/cache.rb
alephant-broker-3.10.0 lib/alephant/broker/cache.rb