Versions in this module Expand all Collapse all v0 v0.1.1 Mar 15, 2023 Changes in this version + func DisableLog() + func UseLogger(logger btclog.Logger) + 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 *btcutil.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 *btcutil.Block, flags blockchain.BehaviorFlags) (bool, error) + func (sm *SyncManager) QueueBlock(block *btcutil.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) QueueNotFound(notFound *wire.MsgNotFound, peer *peerpkg.Peer) + func (sm *SyncManager) QueueTx(tx *btcutil.Tx, peer *peerpkg.Peer, done chan struct{}) + func (sm *SyncManager) Start() + func (sm *SyncManager) Stop() error + func (sm *SyncManager) SyncPeerID() int32
Go to main page