resolvers

package
v1.4.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 19, 2023 License: GPL-3.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Source Files

View all Source files

Directories

Path Synopsis
disabled

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.