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
|
# frozen_string_literal: true
require "helper"
# ruby -w -Itest test/cluster_client_replicas_test.rb
class TestClusterClientReplicas < Minitest::Test
include Helper::Cluster
def test_client_can_command_with_replica
r = build_another_client(replica: true)
100.times do |i|
assert_equal 'OK', r.set("key#{i}", i)
end
r.wait(1, TIMEOUT.to_i * 1000)
100.times do |i|
assert_equal i.to_s, r.get("key#{i}")
end
end
def test_client_can_flush_with_replica
r = build_another_client(replica: true)
assert_equal 'OK', r.flushall
assert_equal 'OK', r.flushdb
end
def test_some_reference_commands_are_sent_to_slaves_if_needed
skip("This test is very flaky") if ENV["CI"]
r = build_another_client(replica: true)
5.times { |i| r.set("key#{i}", i) }
r.wait(1, TIMEOUT.to_i * 1000)
assert_equal %w[key0 key1 key2 key3 key4], r.keys
assert_equal 5, r.dbsize
end
end
|
