Custom CacheBackend

[diegosteiner]

Sowas:

class DynamicCacheStore
  def initialize(redis_store, fallback_store)
    @redis_store = redis_store
    @fallback_store = fallback_store
    @use_fallback = false
  end

  def fetch(name, options = {}, &block)
    active_store.fetch(name, options, &block)
  rescue => e
    handle_error(e)
    @fallback_store.fetch(name, options, &block)
  end

  def write(name, value, options = {})
    active_store.write(name, value, options)
  rescue => e
    handle_error(e)
    @fallback_store.write(name, value, options)
  end

  def read(name, options = {})
    active_store.read(name, options)
  rescue => e
    handle_error(e)
    @fallback_store.read(name, options)
  end

  private

  def active_store
    if @use_fallback
      @fallback_store
    else
      @redis_store
    end
  end

  def handle_error(error)
    Rails.logger.warn("Redis unavailable (#{error.message}), switching to fallback cache")
    @use_fallback = true
    reset_redis_after_timeout
  end

  def reset_redis_after_timeout
    Thread.new do
      sleep(30) # Wait for 30 seconds before trying Redis again
      @use_fallback = false
    end
  end
end