mirror
/
redis
mirror of https://github.com/go-redis/redis.git
1
0
Fork 1
Code Issues Packages Projects Releases Wiki Activity

Fix ring comments

This commit is contained in:
Dimitrij Denissenko 2016-07-02 09:07:27 +01:00
parent 1c4c05e970
commit aa063fe0a2
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
ring.go
View File

@ -102,7 +102,7 @@ func (shard *ringShard) Vote(up bool) bool {
// concurrent use by multiple goroutines. // concurrent use by multiple goroutines.
// //
// Ring monitors the state of each shard and removes dead shards from // 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 // gives you maximum availability and partition tolerance, but no
// consistency between different shards or even clients. Each client // consistency between different shards or even clients. Each client
// uses shards that are available to the client and does not do any // 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() { func (c *Ring) heartbeat() {
ticker := time.NewTicker(100 * time.Millisecond) ticker := time.NewTicker(100 * time.Millisecond)
defer ticker.Stop() defer ticker.Stop()