syncutils

type Options struct {
	Host   host.Host
	PubSub *pubsub.PubSub
	Log    *oplog.Log

	// OnSynced is called, one entry at a time, for every head received
	// from a peer, either in a heads exchange or as a published update.
	OnSynced func(ctx context.Context, entry *oplog.Entry)
	// OnJoin is called when a heads exchange with a peer has completed,
	// with the local heads at that moment.
	OnJoin func(p peer.ID, heads []*oplog.Entry)
	// OnLeave is called when a peer leaves the topic or disconnects.
	OnLeave func(p peer.ID)
	// OnError is called for errors that happen in the background.
	OnError func(err error)

	// Timeout bounds each heads exchange. Defaults to DefaultTimeout.
	Timeout time.Duration
	// DisableAutoStart leaves the protocol stopped until Start is called.
	DisableAutoStart bool
}

type Sync struct {
	// contains filtered or unexported fields
}