1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
|
# encoding: UTF-8
require File.expand_path("helper", File.dirname(__FILE__))
class TestDistributedInternals < Test::Unit::TestCase
include Helper::Distributed
def test_provides_a_meaningful_inspect
nodes = ["redis://localhost:#{PORT}/15", *NODES]
redis = Redis::Distributed.new nodes
assert_equal "#<Redis client v#{Redis::VERSION} for #{redis.nodes.map(&:id).join(', ')}>", redis.inspect
end
def test_default_as_urls
nodes = ["redis://localhost:#{PORT}/15", *NODES]
redis = Redis::Distributed.new nodes
assert_equal ["redis://localhost:#{PORT}/15", *NODES], redis.nodes.map { |node| node.client.id}
end
def test_default_as_config_hashes
nodes = [OPTIONS.merge(:host => '127.0.0.1'), OPTIONS.merge(:host => 'somehost', :port => PORT.next)]
redis = Redis::Distributed.new nodes
assert_equal ["redis://127.0.0.1:#{PORT}/15","redis://somehost:#{PORT.next}/15"], redis.nodes.map { |node| node.client.id }
end
def test_as_mix_and_match
nodes = ["redis://127.0.0.1:7389/15", OPTIONS.merge(:host => 'somehost'), OPTIONS.merge(:host => 'somehost', :port => PORT.next)]
redis = Redis::Distributed.new nodes
assert_equal ["redis://127.0.0.1:7389/15", "redis://somehost:#{PORT}/15", "redis://somehost:#{PORT.next}/15"], redis.nodes.map { |node| node.client.id }
end
def test_override_id
nodes = [OPTIONS.merge(:host => '127.0.0.1', :id => "test"), OPTIONS.merge( :host => 'somehost', :port => PORT.next, :id => "test1")]
redis = Redis::Distributed.new nodes
assert_equal redis.nodes.first.client.id, "test"
assert_equal redis.nodes.last.client.id, "test1"
assert_equal "#<Redis client v#{Redis::VERSION} for #{redis.nodes.map(&:id).join(', ')}>", redis.inspect
end
def test_can_be_duped_to_create_a_new_connection
redis = Redis::Distributed.new(NODES)
clients = redis.info[0]["connected_clients"].to_i
r2 = redis.dup
r2.ping
assert_equal clients + 1, redis.info[0]["connected_clients"].to_i
end
def test_keeps_options_after_dup
r1 = Redis::Distributed.new(NODES, :tag => /^(\w+):/)
assert_raise(Redis::Distributed::CannotDistribute) do
r1.sinter("foo", "bar")
end
assert_equal [], r1.sinter("baz:foo", "baz:bar")
r2 = r1.dup
assert_raise(Redis::Distributed::CannotDistribute) do
r2.sinter("foo", "bar")
end
assert_equal [], r2.sinter("baz:foo", "baz:bar")
end
def test_colliding_node_ids
nodes = ["redis://localhost:#{PORT}/15", "redis://localhost:#{PORT}/15", *NODES]
assert_raise(RuntimeError) do
redis = Redis::Distributed.new nodes
end
end
end
|
