Contents

class Redis
  class DistributedMarshaled < Distributed
    attr_reader :ring

    def initialize(addresses)
      nodes = addresses.map do |address|
        MarshaledClient.new address
      end
      @ring = Redis::HashRing.new nodes
    end

    def nodes
      ring.nodes
    end

    alias_method :flushdb, :delete_cloud!
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
redis-store-0.3.8	lib/redis/distributed_marshaled.rb