requestHandlers

Documentation

Index

• type HashSliceResolver
• type ResolverRequestHandler
  • func NewMetaResolverRequestHandler(finder dataRetriever.ResolversFinder, hdrRequestTopic string) (*ResolverRequestHandler, error)
  • func NewShardResolverRequestHandler(finder dataRetriever.ResolversFinder, txRequestTopic string, ...) (*ResolverRequestHandler, error)
  • func (rrh *ResolverRequestHandler) RequestHeader(shardId uint32, hash []byte)
  • func (rrh *ResolverRequestHandler) RequestHeaderByNonce(destShardID uint32, nonce uint64)
  • func (rrh *ResolverRequestHandler) RequestMiniBlock(shardId uint32, miniblockHash []byte)
  • func (rrh *ResolverRequestHandler) RequestSmartContractResults(destShardID uint32, scrHashes [][]byte)
  • func (rrh *ResolverRequestHandler) RequestTransaction(destShardID uint32, txHashes [][]byte)

Types

type HashSliceResolver

type HashSliceResolver interface {
	RequestDataFromHashArray(hashes [][]byte) error
}

HashSliceResolver can request multiple hashes at once

type ResolverRequestHandler

type ResolverRequestHandler struct {
	// contains filtered or unexported fields
}

func NewMetaResolverRequestHandler

func NewMetaResolverRequestHandler(
	finder dataRetriever.ResolversFinder,
	hdrRequestTopic string,
) (*ResolverRequestHandler, error)

NewMetaResolverRequestHandler creates a requestHandler interface implementation with request functions

func NewShardResolverRequestHandler

func NewShardResolverRequestHandler(
	finder dataRetriever.ResolversFinder,
	txRequestTopic string,
	scrRequestTopic string,
	mbRequestTopic string,
	hdrRequestTopic string,
	maxTxsToRequest int,
) (*ResolverRequestHandler, error)

NewShardResolverRequestHandler creates a requestHandler interface implementation with request functions

func (*ResolverRequestHandler) RequestHeader

func (rrh *ResolverRequestHandler) RequestHeader(shardId uint32, hash []byte)

RequestHeader method asks for header from the connected peers

func (*ResolverRequestHandler) RequestHeaderByNonce

func (rrh *ResolverRequestHandler) RequestHeaderByNonce(destShardID uint32, nonce uint64)

RequestHeaderByNonce method asks for transactions from the connected peers

func (*ResolverRequestHandler) RequestMiniBlock

func (rrh *ResolverRequestHandler) RequestMiniBlock(shardId uint32, miniblockHash []byte)

RequestMiniBlock method asks for miniblocks from the connected peers

func (*ResolverRequestHandler) RequestSmartContractResults

func (rrh *ResolverRequestHandler) RequestSmartContractResults(destShardID uint32, scrHashes [][]byte)

RequestSmartContractResults method asks for smart contract results from the connected peers

func (*ResolverRequestHandler) RequestTransaction

func (rrh *ResolverRequestHandler) RequestTransaction(destShardID uint32, txHashes [][]byte)

RequestTransaction method asks for transactions from the connected peers