Method getPeerSync

onecache/replicator.go:205–216

getPeerSync returns the peer if it has been creaated, and other wise creates it.

(peer string)

// getPeerSync returns the peer if it has been creaated, and other wise creates
// it.
func (r *replicator) getPeerSync(peer string) *peerSync {
	r.lock.Lock()
	defer r.lock.Unlock()
	p, ok := r.peers[peer]
	if ok {
		return p
	}

	p = newPeerSync(peer, r)
	r.peers[peer] = p
	return p
}

// peerSync is used to replicate keys to a particular peer
type peerSync struct {