diff --git a/ring.go b/ring.go index facf3e61..ff77f4d6 100644 --- a/ring.go +++ b/ring.go @@ -95,7 +95,7 @@ func (shard *ringShard) Vote(up bool) bool { // keys across multiple Redis servers (shards). It's safe for // concurrent use by multiple goroutines. // -// It monitors the state of each shard and removes dead shards from +// Ring monitors the state of each shard and removes dead shards from // the ring. When shard comes online it is added back to the ring. This // gives you maximum availability and partition tolerance, but no // consistency between different shards or even clients. Each client diff --git a/ring_test.go b/ring_test.go index 5b52b320..55eb90dd 100644 --- a/ring_test.go +++ b/ring_test.go @@ -56,7 +56,7 @@ var _ = Describe("Redis ring", func() { // Ring needs 5 * heartbeat time to detect that node is down. // Give it more to be sure. heartbeat := 100 * time.Millisecond - time.Sleep(5*heartbeat + heartbeat) + time.Sleep(5*heartbeat + 2*heartbeat) setRingKeys()