Versions in this module Expand all Collapse all v1 v1.1.1 Jan 13, 2024 v1.1.0 Jan 13, 2024 Changes in this version + const TransactionIDPropagationInterval + var ErrPingTimeout = protocolerrors.New(false, "timeout expired on ping") + type FlowContext struct + func New(cfg *config.Config, domain domain.Domain, ...) *FlowContext + func (*FlowContext) HandleError(err error, flowName string, isStopping *uint32, errChan chan<- error) + func (*FlowContext) IsRecoverableError(err error) bool + func (f *FlowContext) AddBlock(block *externalapi.DomainBlock) error + func (f *FlowContext) AddOrphan(orphanBlock *externalapi.DomainBlock) + func (f *FlowContext) AddToPeers(peer *peerpkg.Peer) error + func (f *FlowContext) AddTransaction(tx *externalapi.DomainTransaction, allowOrphan bool) error + func (f *FlowContext) AddressManager() *addressmanager.AddressManager + func (f *FlowContext) Broadcast(message appmessage.Message) error + func (f *FlowContext) Close() + func (f *FlowContext) Config() *config.Config + func (f *FlowContext) ConnectionManager() *connmanager.ConnectionManager + func (f *FlowContext) Domain() domain.Domain + func (f *FlowContext) EnqueueTransactionIDsForPropagation(transactionIDs []*externalapi.DomainTransactionID) error + func (f *FlowContext) GetOrphanRoots(orphan *externalapi.DomainHash) ([]*externalapi.DomainHash, bool, error) + func (f *FlowContext) HasPeers() bool + func (f *FlowContext) IBDPeer() *peerpkg.Peer + func (f *FlowContext) IsIBDRunning() bool + func (f *FlowContext) IsNearlySynced() (bool, error) + func (f *FlowContext) IsOrphan(blockHash *externalapi.DomainHash) bool + func (f *FlowContext) NetAdapter() *netadapter.NetAdapter + func (f *FlowContext) OnNewBlock(block *externalapi.DomainBlock) error + func (f *FlowContext) OnNewBlockTemplate() error + func (f *FlowContext) OnPruningPointUTXOSetOverride() error + func (f *FlowContext) OnTransactionAddedToMempool() + func (f *FlowContext) Peers() []*peerpkg.Peer + func (f *FlowContext) RemoveFromPeers(peer *peerpkg.Peer) + func (f *FlowContext) SetOnNewBlockTemplateHandler(onNewBlockTemplateHandler OnNewBlockTemplateHandler) + func (f *FlowContext) SetOnPruningPointUTXOSetOverrideHandler(onPruningPointUTXOSetOverrideHandler OnPruningPointUTXOSetOverrideHandler) + func (f *FlowContext) SetOnTransactionAddedToMempoolHandler(onTransactionAddedToMempoolHandler OnTransactionAddedToMempoolHandler) + func (f *FlowContext) SharedRequestedBlocks() *SharedRequestedBlocks + func (f *FlowContext) SharedRequestedTransactions() *SharedRequestedTransactions + func (f *FlowContext) ShutdownChan() <-chan struct{} + func (f *FlowContext) TrySetIBDRunning(ibdPeer *peerpkg.Peer) bool + func (f *FlowContext) UnorphanBlocks(rootBlock *externalapi.DomainBlock) ([]*externalapi.DomainBlock, error) + func (f *FlowContext) UnsetIBDRunning() + type OnNewBlockTemplateHandler func() error + type OnPruningPointUTXOSetOverrideHandler func() error + type OnTransactionAddedToMempoolHandler func() + type SharedRequestedBlocks struct + func NewSharedRequestedBlocks() *SharedRequestedBlocks + func (s *SharedRequestedBlocks) AddIfNotExists(hash *externalapi.DomainHash) (exists bool) + func (s *SharedRequestedBlocks) Remove(hash *externalapi.DomainHash) + func (s *SharedRequestedBlocks) RemoveSet(blockHashes map[externalapi.DomainHash]struct{}) + type SharedRequestedTransactions struct + func NewSharedRequestedTransactions() *SharedRequestedTransactions + func (s *SharedRequestedTransactions) AddIfNotExists(txID *externalapi.DomainTransactionID) (exists bool) + func (s *SharedRequestedTransactions) Remove(txID *externalapi.DomainTransactionID) + func (s *SharedRequestedTransactions) RemoveMany(txIDs []*externalapi.DomainTransactionID)
Go to main page