sync

Documentation

Index

• Constants
• type Callback
• type Manager
  • func NewSyncManager(db db.Database, nm module.NetworkManager, plt Platform, logger log.Logger) *Manager
  • func (m *Manager) NewSyncer(ah, prh, nrh, vh, ed []byte) Syncer
  • func (m *Manager) OnFailure(err error, pi module.ProtocolInfo, b []byte)
  • func (m *Manager) OnJoin(id module.PeerID)
  • func (m *Manager) OnLeave(id module.PeerID)
  • func (m *Manager) OnReceive(pi module.ProtocolInfo, b []byte, id module.PeerID) (bool, error)
• type Platform
• type Request
• type Result
• type Syncer

Constants

const (
	NoError errCode = iota
	ErrTimeExpired
	ErrNoData
)

Types

type Callback

type Callback interface {
	// contains filtered or unexported methods
}

type Manager

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

func NewSyncManager

func NewSyncManager(db db.Database, nm module.NetworkManager, plt Platform, logger log.Logger) *Manager

func (*Manager) NewSyncer

func (m *Manager) NewSyncer(ah, prh, nrh, vh, ed []byte) Syncer

func (*Manager) OnFailure

func (m *Manager) OnFailure(err error, pi module.ProtocolInfo, b []byte)

func (*Manager) OnJoin

func (m *Manager) OnJoin(id module.PeerID)

func (*Manager) OnLeave

func (m *Manager) OnLeave(id module.PeerID)

func (*Manager) OnReceive

func (m *Manager) OnReceive(pi module.ProtocolInfo, b []byte,
	id module.PeerID) (bool, error)

type Platform

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

type Request

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

type Result

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

type Syncer

type Syncer interface {
	ForceSync() (*Result, error)
	Stop()
	Finalize() error
}