Skip to content

Commit aa9013b

Browse files
authored
Release 0.0.6 (#40)
1 parent 22cbbb8 commit aa9013b

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

redis-cluster-client.gemspec

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
Gem::Specification.new do |s|
44
s.name = 'redis-cluster-client'
55
s.summary = 'A Redis cluster client for Ruby'
6-
s.version = '0.0.5'
6+
s.version = '0.0.6'
77
s.license = 'MIT'
88
s.homepage = 'https://github.com/redis-rb/redis-cluster-client'
99
s.authors = ['Taishi Kasuga']

test/test_against_cluster_state.rb

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -37,14 +37,15 @@ def test_the_state_of_cluster_failover
3737
end
3838

3939
def test_the_state_of_cluster_resharding
40-
@client.pipelined { |pipeline| 100_000.times { |i| pipeline.call('SET', "{key}#{i}", i) } }
40+
@client.pipelined { |pipeline| 10_000.times { |i| pipeline.call('SET', "{key}#{i}", i) } }
41+
wait_for_replication
4142

4243
slot = SLOT_SIZE.times.max_by { |i| @client.call('CLUSTER', 'COUNTKEYSINSLOT', i) }
4344
src = @client.instance_variable_get(:@node).find_node_key_of_primary(slot)
4445
dest = @client.instance_variable_get(:@node).primary_node_keys.reject { |k| k == src }.sample
4546

4647
@controller.start_resharding(slot: slot, src_node_key: src, dest_node_key: dest)
47-
100_000.times { |i| assert_equal(i.to_s, @client.call('GET', "{key}#{i}"), "Case: GET: #{i}") }
48+
10_000.times { |i| assert_equal(i.to_s, @client.call('GET', "{key}#{i}"), "Case: GET: #{i}") }
4849
@controller.finish_resharding(slot: slot, dest_node_key: dest)
4950
end
5051

0 commit comments

Comments
 (0)