Function newReplicator

onecache/replicator.go:65–71

NewReplicator returns a replicator for the passed node.

(n *Node)

// NewReplicator returns a replicator for the passed node.
func newReplicator(n *Node) *replicator {
	return &replicator{
		n:     n,
		peers: make(map[string]*peerSync),
		quit:  make(chan struct{}),
	}
}

// Stop stops replication.
func (r *replicator) Stop() {