Method getGCKeys

onecache/onecache.go:320–339

getGCKeys returns keys that should be GC'd and whether there should be a follow up GC because keys are being replicated.

()

// getGCKeys returns keys that should be GC'd and whether there should be a
// follow up GC because keys are being replicated.
func (n *Node) getGCKeys() ([]string, bool) {
	keys := n.data.List()
	var gc []string
	var replicating bool
	for _, key := range keys {
		replicas := n.ring.replicaPeers(key)
		for _, replica := range replicas {
			if replica == n.name {
				if n.replicator.IsReplicating(key) {
					replicating = true
					continue
				}
				gc = append(gc, key)
				break
			}
		}
	}

	return gc, replicating
}