Contents

# frozen_string_literal: true

require "active_support/core_ext/module/delegation"

class Kredis::Types::Proxying
  attr_accessor :proxy, :key

  def self.proxying(*commands)
    delegate(*commands, to: :proxy)
  end

  def initialize(redis, key, **options)
    @redis = redis
    @key = key
    @proxy = Kredis::Types::Proxy.new(redis, key)
    options.each { |key, value| send("#{key}=", value) }
  end

  def failsafe(returning: nil, &block)
    proxy.suppress_failsafe_with(returning: returning, &block)
  end

  def unproxied_redis
    # Generally, this should not be used. It's only here for the rare case where we need to
    # call Redis commands that don't reference a key and don't want to be pipelined.
    @redis
  end

  private
    delegate :type_to_string, :string_to_type, :types_to_strings, :strings_to_types, to: :Kredis
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
kredis-1.7.0	lib/kredis/types/proxying.rb
kredis-1.6.1	lib/kredis/types/proxying.rb
kredis-1.6.0	lib/kredis/types/proxying.rb