Function newPeerSync

onecache/replicator.go:230–240

newPeerSync returns a peerSync for replicating to the passed peer.

(peer string, r *replicator)

// newPeerSync returns a peerSync for replicating to the passed peer.
func newPeerSync(peer string, r *replicator) *peerSync {
	p := &peerSync{
		name:    peer,
		tasks:   make(map[string][]replicationTask),
		queue:   make(chan string, 100),
		endSync: make(chan struct{}),
		r:       r,
	}
	go p.replicate()
	return p
}

// Stop stops replication to the peer.
func (p *peerSync) stop() {