diff --git a/ring.go b/ring.go index 8aba07e..8c998a8 100644 --- a/ring.go +++ b/ring.go @@ -102,7 +102,7 @@ func (shard *ringShard) Vote(up bool) bool { // concurrent use by multiple goroutines. // // Ring monitors the state of each shard and removes dead shards from -// the c. When shard comes online it is added back to the c. This +// 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 // uses shards that are available to the client and does not do any @@ -221,7 +221,7 @@ func (c *Ring) rebalance() { } } -// heartbeat monitors state of each shard in the c. +// heartbeat monitors state of each shard in the ring. func (c *Ring) heartbeat() { ticker := time.NewTicker(100 * time.Millisecond) defer ticker.Stop()