sync2

type BucketIDAndBytes struct {
	BkID  db.BucketID
	Bytes []byte
}

type DataHandler func(reqID uint32, sender *peer, data []BucketIDAndBytes)

type DataSender interface {
	RequestData(peer module.PeerID, reqID uint32, reqData []BucketIDAndBytes) error
}

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

type PeerWatcher interface {
	OnPeerJoin(p *peer)
	OnPeerLeave(p *peer)
}

type Platform interface {
	NewExtensionWithBuilder(builder merkle.Builder, raw []byte) state.ExtensionSnapshot
}

type ProgressCallback func(r, u int) error

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

type ReactorV1 struct {
	ReactorCommon
	// contains filtered or unexported fields
}

type ReactorV2 struct {
	ReactorCommon
	// contains filtered or unexported fields
}

type Result struct {
	Wss            state.WorldSnapshot
	PatchReceipts  module.ReceiptList
	NormalReceipts module.ReceiptList
	BTPDigest      module.BTPDigest
}

type SyncProcessor interface {
	Start(cb func(err error))
	Stop()
	AddRequest(id db.BucketID, key []byte) error
	UnresolvedCount() int
}

type SyncReactor interface {
	GetVersion() byte
	WatchPeers(watcher PeerWatcher) []*peer
	UnwatchPeers(watcher PeerWatcher) bool
}

type Syncer interface {
	ForceSync() (*Result, error)
	Stop()
	Finalize() error
	SetProgressCallback(cb ProgressCallback)
	IsForceSyncing() bool
}