Versions in this module Expand all Collapse all v0 v0.9.1 Apr 30, 2019 v0.9.0 Apr 29, 2019 Changes in this version + var Log = cl.NewSubSystem("chain/sync", ll.DEFAULT) + func UseLogger(logger *cl.SubSystem) + type Config struct + Chain *blockchain.BlockChain + ChainParams *chaincfg.Params + DisableCheckpoints bool + FeeEstimator *mempool.FeeEstimator + MaxPeers int + PeerNotifier PeerNotifier + TxMemPool *mempool.TxPool + type PeerNotifier interface + AnnounceNewTransactions func(newTxs []*mempool.TxDesc) + RelayInventory func(invVect *wire.InvVect, data interface{}) + TransactionConfirmed func(tx *util.Tx) + UpdatePeerHeights func(latestBlkHash *chainhash.Hash, latestHeight int32, updateSource *peer.Peer) + type SyncManager struct + func New(config *Config) (*SyncManager, error) + func (sm *SyncManager) DonePeer(peer *peerpkg.Peer) + func (sm *SyncManager) IsCurrent() bool + func (sm *SyncManager) NewPeer(peer *peerpkg.Peer) + func (sm *SyncManager) Pause() chan<- struct{} + func (sm *SyncManager) ProcessBlock(block *util.Block, flags blockchain.BehaviorFlags) (bool, error) + func (sm *SyncManager) QueueBlock(block *util.Block, peer *peerpkg.Peer, done chan struct{}) + func (sm *SyncManager) QueueHeaders(headers *wire.MsgHeaders, peer *peerpkg.Peer) + func (sm *SyncManager) QueueInv(inv *wire.MsgInv, peer *peerpkg.Peer) + func (sm *SyncManager) QueueTx(tx *util.Tx, peer *peerpkg.Peer, done chan struct{}) + func (sm *SyncManager) Start() + func (sm *SyncManager) Stop() error + func (sm *SyncManager) SyncPeerID() int32