Versions in this module Expand all Collapse all v1 v1.9.25 Mar 25, 2021 v1.9.24 Mar 24, 2021 Changes in this version + var D logg.LevelPrinter = logg.GetLogPrinterSet(subsystem) + var E logg.LevelPrinter = logg.GetLogPrinterSet(subsystem) + var F logg.LevelPrinter = logg.GetLogPrinterSet(subsystem) + var I logg.LevelPrinter = logg.GetLogPrinterSet(subsystem) + var T logg.LevelPrinter = logg.GetLogPrinterSet(subsystem) + var W logg.LevelPrinter = logg.GetLogPrinterSet(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 *block2.Block, flags blockchain.BehaviorFlags) (bool, error) + func (sm *SyncManager) QueueBlock(block *block2.Block, peer *peerpkg.Peer, done qu.C) + 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 qu.C) + func (sm *SyncManager) Start() + func (sm *SyncManager) Stop() (e error) + func (sm *SyncManager) SyncPeerID() int32
Go to main page