sync

Documentation

Index

• type Config
• type SyncManager
  • func New(config *Config) (*SyncManager, error)
  • func (manager *SyncManager) AddPeerState(remoteAddr string)
  • func (manager *SyncManager) HandleMessage(msg protocol.Message)
  • func (manager *SyncManager) StartSync()

Types

type Config

type Config struct {
	Chain       *chain.Blockchain
	TxMemPool   *mempool.TxPool
	Peer        *peer.Peer
	AddrManager *addr.AddrManager
	MaxPeers    int
}

Config is a configuration struct used to initialize a new SyncManager.

type SyncManager

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

func New

func New(config *Config) (*SyncManager, error)

New return a new SyncManager with sync config

func (*SyncManager) AddPeerState

func (manager *SyncManager) AddPeerState(remoteAddr string)

AddPeerState create new remote peer state if already exists, not cover it

func (*SyncManager) HandleMessage

func (manager *SyncManager) HandleMessage(msg protocol.Message)

func (*SyncManager) StartSync

func (manager *SyncManager) StartSync()

StartSync start loop sync handle