resolvers

Documentation

Index

• func NewGenericBlockBodyResolver(senderResolver dataRetriever.TopicResolverSender, miniBlockPool storage.Cacher, ...) (*genericBlockBodyResolver, error)
• type HeaderResolver
  • func NewHeaderResolver(senderResolver dataRetriever.TopicResolverSender, headers storage.Cacher, ...) (*HeaderResolver, error)
  • func (hdrRes *HeaderResolver) IsInterfaceNil() bool
  • func (hdrRes *HeaderResolver) ProcessReceivedMessage(message p2p.MessageP2P, _ func(buffToSend []byte)) error
  • func (hdrRes *HeaderResolver) RequestDataFromHash(hash []byte) error
  • func (hdrRes *HeaderResolver) RequestDataFromNonce(nonce uint64) error
• type TxResolver
  • func NewTxResolver(senderResolver dataRetriever.TopicResolverSender, ...) (*TxResolver, error)
  • func (txRes *TxResolver) IsInterfaceNil() bool
  • func (txRes *TxResolver) ProcessReceivedMessage(message p2p.MessageP2P, _ func(buffToSend []byte)) error
  • func (txRes *TxResolver) RequestDataFromHash(hash []byte) error
  • func (txRes *TxResolver) RequestDataFromHashArray(hashes [][]byte) error

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, _ func(buffToSend []byte)) 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, _ func(buffToSend []byte)) 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