AddCache only adds c.circle skips persist.
(node proto.Node)
| 196 | |
| 197 | // AddCache only adds c.circle skips persist. |
| 198 | func (c *Consistent) AddCache(node proto.Node) { |
| 199 | c.cacheLock.Lock() |
| 200 | defer c.cacheLock.Unlock() |
| 201 | |
| 202 | for i := 0; i < c.NumberOfReplicas; i++ { |
| 203 | c.circle[hashKey(c.nodeKey(node.ID, i))] = &node |
| 204 | } |
| 205 | c.updateSortedHashes() |
| 206 | expvar.Get(mwKeyDHTNodeCount).(mw.Metric).Add(float64(len(c.circle) / c.NumberOfReplicas)) |
| 207 | return |
| 208 | } |
| 209 | |
| 210 | // RemoveCache removes an node from the hash cache. |
| 211 | func (c *Consistent) RemoveCache(nodeID proto.NodeID) { |
no test coverage detected