class Redis::DistributedStore

Attributes

ring[R]

Public Class Methods

new(addresses, options = { }) click to toggle source
# File lib/redis/distributed_store.rb, line 8
def initialize(addresses, options = { })
  _extend_namespace options
  @ring = options[:ring] || Redis::HashRing.new([], options[:replicas] || Redis::HashRing::POINTS_PER_SERVER)

  addresses.each do |address|
    @ring.add_node(::Redis::Store.new _merge_options(address, options))
  end
end

Public Instance Methods

get(key, options = nil) click to toggle source
# File lib/redis/distributed_store.rb, line 29
def get(key, options = nil)
  node_for(key).get(key, options)
end
nodes() click to toggle source
# File lib/redis/distributed_store.rb, line 17
def nodes
  ring.nodes
end
reconnect() click to toggle source
# File lib/redis/distributed_store.rb, line 21
def reconnect
  nodes.each {|node| node.reconnect }
end
redis_version() click to toggle source
# File lib/redis/distributed_store.rb, line 37
def redis_version
  nodes.first.redis_version unless nodes.empty?
end
set(key, value, options = nil) click to toggle source
# File lib/redis/distributed_store.rb, line 25
def set(key, value, options = nil)
  node_for(key).set(key, value, options)
end
setex(key, expiry, value, options = nil) click to toggle source
# File lib/redis/distributed_store.rb, line 49
def setex(key, expiry, value, options = nil)
  node_for(key).setex(key, expiry, value, options)
end
setnx(key, value, options = nil) click to toggle source
# File lib/redis/distributed_store.rb, line 33
def setnx(key, value, options = nil)
  node_for(key).setnx(key, value, options)
end
supports_redis_version?(version) click to toggle source
# File lib/redis/distributed_store.rb, line 41
def supports_redis_version?(version)
  if nodes.empty?
    false
  else
    nodes.first.supports_redis_version?(version)
  end
end

Private Instance Methods

_extend_namespace(options) click to toggle source
# File lib/redis/distributed_store.rb, line 54
def _extend_namespace(options)
  @namespace = options[:namespace]
  extend ::Redis::Store::Namespace if @namespace
end
_merge_options(address, options) click to toggle source
# File lib/redis/distributed_store.rb, line 59
def _merge_options(address, options)
  address.merge({
    :timeout => options[:timeout] || @@timeout, 
    :namespace => options[:namespace]
  })
end