Versions in this module Expand all Collapse all v1 v1.1.66 Jun 17, 2021 v1.1.65 Jun 17, 2021 Changes in this version + func NewMiniblockResolver(arg ArgMiniblockResolver) (*miniblockResolver, error) + type ArgHeaderResolver struct + AntifloodHandler dataRetriever.P2PAntifloodHandler + HdrStorage storage.Storer + Headers dataRetriever.HeadersPool + HeadersNoncesStorage storage.Storer + Marshalizer marshal.Marshalizer + NonceConverter typeConverters.Uint64ByteSliceConverter + SenderResolver dataRetriever.TopicResolverSender + ShardCoordinator sharding.Coordinator + Throttler dataRetriever.ResolverThrottler + type ArgMiniblockResolver struct + AntifloodHandler dataRetriever.P2PAntifloodHandler + DataPacker dataRetriever.DataPacker + Marshalizer marshal.Marshalizer + MiniBlockPool storage.Cacher + MiniBlockStorage storage.Storer + SenderResolver dataRetriever.TopicResolverSender + Throttler dataRetriever.ResolverThrottler + type ArgTrieNodeResolver struct + AntifloodHandler dataRetriever.P2PAntifloodHandler + Marshalizer marshal.Marshalizer + SenderResolver dataRetriever.TopicResolverSender + Throttler dataRetriever.ResolverThrottler + TrieDataGetter dataRetriever.TrieDataGetter + type ArgTxResolver struct + AntifloodHandler dataRetriever.P2PAntifloodHandler + DataPacker dataRetriever.DataPacker + Marshalizer marshal.Marshalizer + SenderResolver dataRetriever.TopicResolverSender + Throttler dataRetriever.ResolverThrottler + TxPool dataRetriever.ShardedDataCacherNotifier + TxStorage storage.Storer + type HeaderResolver struct + func NewHeaderResolver(arg ArgHeaderResolver) (*HeaderResolver, error) + func (hdrRes *HeaderResolver) IsInterfaceNil() bool + func (hdrRes *HeaderResolver) NumPeersToQuery() (int, int) + func (hdrRes *HeaderResolver) ProcessReceivedMessage(message p2p.MessageP2P, fromConnectedPeer core.PeerID) error + func (hdrRes *HeaderResolver) RequestDataFromEpoch(identifier []byte) error + func (hdrRes *HeaderResolver) RequestDataFromHash(hash []byte, epoch uint32) error + func (hdrRes *HeaderResolver) RequestDataFromNonce(nonce uint64, epoch uint32) error + func (hdrRes *HeaderResolver) SetEpochHandler(epochHandler dataRetriever.EpochHandler) error + func (hdrRes *HeaderResolver) SetNumPeersToQuery(intra int, cross int) + func (hdrRes *HeaderResolver) SetResolverDebugHandler(handler dataRetriever.ResolverDebugHandler) error + type TrieNodeResolver struct + func NewTrieNodeResolver(arg ArgTrieNodeResolver) (*TrieNodeResolver, error) + func (tnRes *TrieNodeResolver) IsInterfaceNil() bool + func (tnRes *TrieNodeResolver) NumPeersToQuery() (int, int) + func (tnRes *TrieNodeResolver) ProcessReceivedMessage(message p2p.MessageP2P, fromConnectedPeer core.PeerID) error + func (tnRes *TrieNodeResolver) RequestDataFromHash(hash []byte, _ uint32) error + func (tnRes *TrieNodeResolver) RequestDataFromHashArray(hashes [][]byte, _ uint32) error + func (tnRes *TrieNodeResolver) SetNumPeersToQuery(intra int, cross int) + func (tnRes *TrieNodeResolver) SetResolverDebugHandler(handler dataRetriever.ResolverDebugHandler) error + type TxResolver struct + func NewTxResolver(arg ArgTxResolver) (*TxResolver, error) + func (txRes *TxResolver) IsInterfaceNil() bool + func (txRes *TxResolver) NumPeersToQuery() (int, int) + func (txRes *TxResolver) ProcessReceivedMessage(message p2p.MessageP2P, fromConnectedPeer core.PeerID) error + func (txRes *TxResolver) RequestDataFromHash(hash []byte, epoch uint32) error + func (txRes *TxResolver) RequestDataFromHashArray(hashes [][]byte, epoch uint32) error + func (txRes *TxResolver) SetNumPeersToQuery(intra int, cross int) + func (txRes *TxResolver) SetResolverDebugHandler(handler dataRetriever.ResolverDebugHandler) error
Go to main page