resolvers

Documentation

Index

• func NewMiniblockResolver(arg ArgMiniblockResolver) (*miniblockResolver, error)
• func NewPeerAuthenticationResolver(arg ArgPeerAuthenticationResolver) (*peerAuthenticationResolver, error)
• func NewValidatorInfoResolver(args ArgValidatorInfoResolver) (*validatorInfoResolver, error)
• type ArgBaseResolver
• type ArgHeaderResolver
• type ArgMiniblockResolver
• type ArgPeerAuthenticationResolver
• type ArgTrieNodeResolver
• type ArgTxResolver
• type ArgValidatorInfoResolver
• type HeaderResolver
  • func NewHeaderResolver(arg ArgHeaderResolver) (*HeaderResolver, error)
  • func (res HeaderResolver) Close() error
  • func (hdrRes *HeaderResolver) IsInterfaceNil() bool
  • func (res 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 (res HeaderResolver) SetNumPeersToQuery(intra int, cross int)
  • func (res HeaderResolver) SetResolverDebugHandler(handler dataRetriever.ResolverDebugHandler) error
• type TrieNodeResolver
  • func NewTrieNodeResolver(arg ArgTrieNodeResolver) (*TrieNodeResolver, error)
  • func (res TrieNodeResolver) Close() error
  • func (tnRes *TrieNodeResolver) IsInterfaceNil() bool
  • func (res 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) RequestDataFromReferenceAndChunk(hash []byte, chunkIndex uint32) error
  • func (res TrieNodeResolver) SetNumPeersToQuery(intra int, cross int)
  • func (res TrieNodeResolver) SetResolverDebugHandler(handler dataRetriever.ResolverDebugHandler) error
• type TxResolver
  • func NewTxResolver(arg ArgTxResolver) (*TxResolver, error)
  • func (res TxResolver) Close() error
  • func (txRes *TxResolver) IsInterfaceNil() bool
  • func (res 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 (res TxResolver) SetNumPeersToQuery(intra int, cross int)
  • func (res TxResolver) SetResolverDebugHandler(handler dataRetriever.ResolverDebugHandler) error

Functions

func NewMiniblockResolver

func NewMiniblockResolver(arg ArgMiniblockResolver) (*miniblockResolver, error)

NewMiniblockResolver creates a miniblock resolver

func NewPeerAuthenticationResolver

func NewPeerAuthenticationResolver(arg ArgPeerAuthenticationResolver) (*peerAuthenticationResolver, error)

NewPeerAuthenticationResolver creates a peer authentication resolver

func NewValidatorInfoResolver

func NewValidatorInfoResolver(args ArgValidatorInfoResolver) (*validatorInfoResolver, error)

NewValidatorInfoResolver creates a validator info resolver

Types

type ArgBaseResolver

type ArgBaseResolver struct {
	SenderResolver   dataRetriever.TopicResolverSender
	Marshaller       marshal.Marshalizer
	AntifloodHandler dataRetriever.P2PAntifloodHandler
	Throttler        dataRetriever.ResolverThrottler
}

ArgBaseResolver is the argument structure used as base to create a new a resolver instance

type ArgHeaderResolver

type ArgHeaderResolver struct {
	ArgBaseResolver
	Headers              dataRetriever.HeadersPool
	HdrStorage           storage.Storer
	HeadersNoncesStorage storage.Storer
	NonceConverter       typeConverters.Uint64ByteSliceConverter
	ShardCoordinator     sharding.Coordinator
	IsFullHistoryNode    bool
}

ArgHeaderResolver is the argument structure used to create new HeaderResolver instance

type ArgMiniblockResolver

type ArgMiniblockResolver struct {
	ArgBaseResolver
	MiniBlockPool     storage.Cacher
	MiniBlockStorage  storage.Storer
	DataPacker        dataRetriever.DataPacker
	IsFullHistoryNode bool
}

ArgMiniblockResolver is the argument structure used to create a new miniblockResolver instance

type ArgPeerAuthenticationResolver

type ArgPeerAuthenticationResolver struct {
	ArgBaseResolver
	PeerAuthenticationPool storage.Cacher
	DataPacker             dataRetriever.DataPacker
	PayloadValidator       dataRetriever.PeerAuthenticationPayloadValidator
}

ArgPeerAuthenticationResolver is the argument structure used to create a new peer authentication resolver instance

type ArgTrieNodeResolver

type ArgTrieNodeResolver struct {
	ArgBaseResolver
	TrieDataGetter dataRetriever.TrieDataGetter
}

ArgTrieNodeResolver is the argument structure used to create new TrieNodeResolver instance

type ArgTxResolver

type ArgTxResolver struct {
	ArgBaseResolver
	TxPool            dataRetriever.ShardedDataCacherNotifier
	TxStorage         storage.Storer
	DataPacker        dataRetriever.DataPacker
	IsFullHistoryNode bool
}

ArgTxResolver is the argument structure used to create new TxResolver instance

type ArgValidatorInfoResolver

type ArgValidatorInfoResolver struct {
	SenderResolver       dataRetriever.TopicResolverSender
	Marshaller           marshal.Marshalizer
	AntifloodHandler     dataRetriever.P2PAntifloodHandler
	Throttler            dataRetriever.ResolverThrottler
	ValidatorInfoPool    dataRetriever.ShardedDataCacherNotifier
	ValidatorInfoStorage storage.Storer
	DataPacker           dataRetriever.DataPacker
	IsFullHistoryNode    bool
}

ArgValidatorInfoResolver is the argument structure used to create a new validator info resolver instance

type HeaderResolver

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

HeaderResolver is a wrapper over Resolver that is specialized in resolving headers requests

func NewHeaderResolver

func NewHeaderResolver(arg ArgHeaderResolver) (*HeaderResolver, error)

NewHeaderResolver creates a new header resolver

func (HeaderResolver) Close

func (res HeaderResolver) Close() error

Close returns nil

func (*HeaderResolver) IsInterfaceNil

func (hdrRes *HeaderResolver) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (HeaderResolver) NumPeersToQuery

func (res HeaderResolver) NumPeersToQuery() (int, int)

NumPeersToQuery will return the number of intra shard and cross shard number of peer to query

func (*HeaderResolver) ProcessReceivedMessage

func (hdrRes *HeaderResolver) ProcessReceivedMessage(message p2p.MessageP2P, fromConnectedPeer core.PeerID) 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) RequestDataFromEpoch

func (hdrRes *HeaderResolver) RequestDataFromEpoch(identifier []byte) error

RequestDataFromEpoch requests a header from other peers having input the epoch

func (*HeaderResolver) RequestDataFromHash

func (hdrRes *HeaderResolver) RequestDataFromHash(hash []byte, epoch uint32) error

RequestDataFromHash requests a header from other peers having input the hdr hash

func (*HeaderResolver) RequestDataFromNonce

func (hdrRes *HeaderResolver) RequestDataFromNonce(nonce uint64, epoch uint32) error

RequestDataFromNonce requests a header from other peers having input the hdr nonce

func (*HeaderResolver) SetEpochHandler

func (hdrRes *HeaderResolver) SetEpochHandler(epochHandler dataRetriever.EpochHandler) error

SetEpochHandler sets the epoch handler for this component

func (HeaderResolver) SetNumPeersToQuery

func (res HeaderResolver) SetNumPeersToQuery(intra int, cross int)

SetNumPeersToQuery will set the number of intra shard and cross shard number of peer to query

func (HeaderResolver) SetResolverDebugHandler

func (res HeaderResolver) SetResolverDebugHandler(handler dataRetriever.ResolverDebugHandler) error

SetResolverDebugHandler will set a resolver debug handler

type TrieNodeResolver

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

TrieNodeResolver is a wrapper over Resolver that is specialized in resolving trie node requests

func NewTrieNodeResolver

func NewTrieNodeResolver(arg ArgTrieNodeResolver) (*TrieNodeResolver, error)

NewTrieNodeResolver creates a new trie node resolver

func (TrieNodeResolver) Close

func (res TrieNodeResolver) Close() error

Close returns nil

func (*TrieNodeResolver) IsInterfaceNil

func (tnRes *TrieNodeResolver) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (TrieNodeResolver) NumPeersToQuery

func (res TrieNodeResolver) NumPeersToQuery() (int, int)

NumPeersToQuery will return the number of intra shard and cross shard number of peer to query

func (*TrieNodeResolver) ProcessReceivedMessage

func (tnRes *TrieNodeResolver) ProcessReceivedMessage(message p2p.MessageP2P, fromConnectedPeer core.PeerID) 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 (*TrieNodeResolver) RequestDataFromHash

func (tnRes *TrieNodeResolver) RequestDataFromHash(hash []byte, _ uint32) error

RequestDataFromHash requests trie nodes from other peers having input a trie node hash

func (*TrieNodeResolver) RequestDataFromHashArray

func (tnRes *TrieNodeResolver) RequestDataFromHashArray(hashes [][]byte, _ uint32) error

RequestDataFromHashArray requests trie nodes from other peers having input multiple trie node hashes

func (*TrieNodeResolver) RequestDataFromReferenceAndChunk

func (tnRes *TrieNodeResolver) RequestDataFromReferenceAndChunk(hash []byte, chunkIndex uint32) error

RequestDataFromReferenceAndChunk requests a trie node's chunk by specifying the reference and the chunk index

func (TrieNodeResolver) SetNumPeersToQuery

func (res TrieNodeResolver) SetNumPeersToQuery(intra int, cross int)

SetNumPeersToQuery will set the number of intra shard and cross shard number of peer to query

func (TrieNodeResolver) SetResolverDebugHandler

func (res TrieNodeResolver) SetResolverDebugHandler(handler dataRetriever.ResolverDebugHandler) error

SetResolverDebugHandler will set a resolver debug handler

type TxResolver

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

TxResolver is a wrapper over Resolver that is specialized in resolving transaction requests

func NewTxResolver

func NewTxResolver(arg ArgTxResolver) (*TxResolver, error)

NewTxResolver creates a new transaction resolver

func (TxResolver) Close

func (res TxResolver) Close() error

Close returns nil

func (*TxResolver) IsInterfaceNil

func (txRes *TxResolver) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (TxResolver) NumPeersToQuery

func (res TxResolver) NumPeersToQuery() (int, int)

NumPeersToQuery will return the number of intra shard and cross shard number of peer to query

func (*TxResolver) ProcessReceivedMessage

func (txRes *TxResolver) ProcessReceivedMessage(message p2p.MessageP2P, fromConnectedPeer core.PeerID) 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, epoch uint32) error

RequestDataFromHash requests a transaction from other peers having input the tx hash

func (*TxResolver) RequestDataFromHashArray

func (txRes *TxResolver) RequestDataFromHashArray(hashes [][]byte, epoch uint32) error

RequestDataFromHashArray requests a list of tx hashes from other peers

func (TxResolver) SetNumPeersToQuery

func (res TxResolver) SetNumPeersToQuery(intra int, cross int)

SetNumPeersToQuery will set the number of intra shard and cross shard number of peer to query

func (TxResolver) SetResolverDebugHandler

func (res TxResolver) SetResolverDebugHandler(handler dataRetriever.ResolverDebugHandler) error

SetResolverDebugHandler will set a resolver debug handler