Contents

# encoding: UTF-8

require "helper"

class TestDistributed < Test::Unit::TestCase

  include Helper::Distributed

  def test_handle_multiple_servers
    @r = Redis::Distributed.new ["redis://localhost:#{PORT}/15", *NODES]

    100.times do |idx|
      @r.set(idx.to_s, "foo#{idx}")
    end

    100.times do |idx|
      assert_equal "foo#{idx}", @r.get(idx.to_s)
    end

    assert_equal "0", @r.keys("*").sort.first
    assert_equal "string", @r.type("1")
  end

  def test_add_nodes
    logger = Logger.new("/dev/null")

    @r = Redis::Distributed.new NODES, :logger => logger, :timeout => 10

    assert_equal "127.0.0.1", @r.nodes[0].client.host
    assert_equal PORT, @r.nodes[0].client.port
    assert_equal 15, @r.nodes[0].client.db
    assert_equal 10, @r.nodes[0].client.timeout
    assert_equal logger, @r.nodes[0].client.logger

    @r.add_node("redis://localhost:6380/14")

    assert_equal "localhost", @r.nodes[1].client.host
    assert_equal 6380, @r.nodes[1].client.port
    assert_equal 14, @r.nodes[1].client.db
    assert_equal 10, @r.nodes[1].client.timeout
    assert_equal logger, @r.nodes[1].client.logger
  end

  def test_pipelining_commands_cannot_be_distributed
    assert_raise Redis::Distributed::CannotDistribute do
      r.pipelined do
        r.lpush "foo", "s1"
        r.lpush "foo", "s2"
      end
    end
  end

  def test_unknown_commands_does_not_work_by_default
    assert_raise NoMethodError do
      r.not_yet_implemented_command
    end
  end
end

Version data entries

11 entries across 11 versions & 3 rubygems

Version	Path
redis-3.0.5	test/distributed_test.rb
sidekiq-statsd-0.1.1	vendor/ruby/1.9.1/gems/redis-3.0.4/test/distributed_test.rb
sidekiq-statsd-0.1.0	vendor/ruby/1.9.1/gems/redis-3.0.4/test/distributed_test.rb
redis-3.0.4	test/distributed_test.rb
redis-3.0.3	test/distributed_test.rb
remq-0.0.4	vendor/bundle/gems/redis-3.0.2/test/distributed_test.rb
remq-0.0.3	vendor/bundle/gems/redis-3.0.2/test/distributed_test.rb
redis-3.0.2	test/distributed_test.rb
redis-3.0.1	test/distributed_test.rb
redis-3.0.0	test/distributed_test.rb
redis-3.0.0.rc2	test/distributed_test.rb