sync

Documentation

Index

• Constants
• func PeerIDToKey(p module.PeerID) string
• type Callback
• type Manager
  • func NewSyncManager(db db.Database, nm module.NetworkManager, plt Platform, logger log.Logger) *Manager
  • func (m *Manager) AddRequest(id db.BucketID, key []byte) error
  • func (m *Manager) NewSyncer(ah, prh, nrh, vh, ed []byte, noBuffer bool) Syncer
  • 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)
  • func (m *Manager) SetSyncHandler(sh SyncerImpl, on bool)
  • func (m *Manager) Start()
  • func (m *Manager) Term()
• type Platform
• type Result
• type Syncer
• type SyncerImpl

Constants

const (
	DataRequestEntryLimit    = 20
	DataRequestNodeLimit     = 3
	DataRequestNodeInterval  = time.Millisecond * 300
	DataRequestRoundInterval = time.Second * 3
)

const (
	NoError errCode = iota
	ErrTimeExpired
	ErrNoData
)

Functions

func PeerIDToKey

func PeerIDToKey(p module.PeerID) string

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) AddRequest

func (m *Manager) AddRequest(id db.BucketID, key []byte) error

func (*Manager) NewSyncer

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

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)

func (*Manager) SetSyncHandler

func (m *Manager) SetSyncHandler(sh SyncerImpl, on bool)

func (*Manager) Start

func (m *Manager) Start()

func (*Manager) Term

func (m *Manager) Term()

type Platform

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

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
}

type SyncerImpl

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