Affected by 
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewGenericBlockBodyResolver ¶
func NewGenericBlockBodyResolver( senderResolver dataRetriever.TopicResolverSender, miniBlockPool storage.Cacher, miniBlockStorage storage.Storer, marshalizer marshal.Marshalizer, ) (*genericBlockBodyResolver, error)
NewGenericBlockBodyResolver creates a new block body resolver
Types ¶
type HeaderResolver ¶
type HeaderResolver struct {
dataRetriever.TopicResolverSender
// contains filtered or unexported fields
}
HeaderResolver is a wrapper over Resolver that is specialized in resolving headers requests
func NewHeaderResolver ¶
func NewHeaderResolver( senderResolver dataRetriever.TopicResolverSender, headers storage.Cacher, headersNonces dataRetriever.Uint64SyncMapCacher, hdrStorage storage.Storer, headersNoncesStorage storage.Storer, marshalizer marshal.Marshalizer, nonceConverter typeConverters.Uint64ByteSliceConverter, ) (*HeaderResolver, error)
NewHeaderResolver creates a new header resolver
func (*HeaderResolver) IsInterfaceNil ¶
func (hdrRes *HeaderResolver) IsInterfaceNil() bool
IsInterfaceNil returns true if there is no value under the interface
func (*HeaderResolver) ProcessReceivedMessage ¶
func (hdrRes *HeaderResolver) ProcessReceivedMessage(message p2p.MessageP2P) error
ProcessReceivedMessage will be the callback func from the p2p.Messenger and will be called each time a new message was received (for the topic this validator was registered to, usually a request topic)
func (*HeaderResolver) RequestDataFromHash ¶
func (hdrRes *HeaderResolver) RequestDataFromHash(hash []byte) error
RequestDataFromHash requests a header from other peers having input the hdr hash
func (*HeaderResolver) RequestDataFromNonce ¶
func (hdrRes *HeaderResolver) RequestDataFromNonce(nonce uint64) error
RequestDataFromNonce requests a header from other peers having input the hdr nonce
type TxResolver ¶
type TxResolver struct {
dataRetriever.TopicResolverSender
// contains filtered or unexported fields
}
TxResolver is a wrapper over Resolver that is specialized in resolving transaction requests
func NewTxResolver ¶
func NewTxResolver( senderResolver dataRetriever.TopicResolverSender, txPool dataRetriever.ShardedDataCacherNotifier, txStorage storage.Storer, marshalizer marshal.Marshalizer, dataPacker dataRetriever.DataPacker, ) (*TxResolver, error)
NewTxResolver creates a new transaction resolver
func (*TxResolver) IsInterfaceNil ¶
func (txRes *TxResolver) IsInterfaceNil() bool
IsInterfaceNil returns true if there is no value under the interface
func (*TxResolver) ProcessReceivedMessage ¶
func (txRes *TxResolver) ProcessReceivedMessage(message p2p.MessageP2P) error
ProcessReceivedMessage will be the callback func from the p2p.Messenger and will be called each time a new message was received (for the topic this validator was registered to, usually a request topic)
func (*TxResolver) RequestDataFromHash ¶
func (txRes *TxResolver) RequestDataFromHash(hash []byte) error
RequestDataFromHash requests a transaction from other peers having input the tx hash
func (*TxResolver) RequestDataFromHashArray ¶
func (txRes *TxResolver) RequestDataFromHashArray(hashes [][]byte) error
RequestDataFromHashArray requests a list of tx hashes from other peers
Source Files
Directories