Versions in this module Expand all Collapse all v1 v1.999.0 Nov 17, 2022 Changes in this version + func NewHeartbeatInterceptorProcessor(args ArgHeartbeatInterceptorProcessor) (*heartbeatInterceptorProcessor, error) + func NewPeerAuthenticationInterceptorProcessor(args ArgPeerAuthenticationInterceptorProcessor) (*peerAuthenticationInterceptorProcessor, error) + func NewPeerShardInterceptorProcessor(args ArgPeerShardInterceptorProcessor) (*peerShardInterceptorProcessor, error) + func NewTrieNodeChunksProcessor(arg TrieNodesChunksProcessorArgs) (*trieNodeChunksProcessor, error) + type ArgHdrInterceptorProcessor struct + BlockBlackList process.TimeCacher + Headers dataRetriever.HeadersPool + type ArgHeartbeatInterceptorProcessor struct + HeartbeatCacher storage.Cacher + PeerShardMapper process.PeerShardMapper + ShardCoordinator sharding.Coordinator + type ArgMiniblockInterceptorProcessor struct + Hasher hashing.Hasher + Marshalizer marshal.Marshalizer + MiniblockCache storage.Cacher + ShardCoordinator sharding.Coordinator + WhiteListHandler process.WhiteListHandler + type ArgPeerAuthenticationInterceptorProcessor struct + HardforkTrigger heartbeat.HardforkTrigger + Marshaller marshal.Marshalizer + PeerAuthenticationCacher storage.Cacher + PeerShardMapper process.PeerShardMapper + type ArgPeerShardInterceptorProcessor struct + PeerShardMapper process.PeerShardMapper + type ArgTxInterceptorProcessor struct + ShardedDataCache dataRetriever.ShardedDataCacherNotifier + TxValidator process.TxValidator + type HdrInterceptorProcessor struct + func NewHdrInterceptorProcessor(argument *ArgHdrInterceptorProcessor) (*HdrInterceptorProcessor, error) + func (hip *HdrInterceptorProcessor) IsInterfaceNil() bool + func (hip *HdrInterceptorProcessor) RegisterHandler(handler func(topic string, hash []byte, data interface{})) + func (hip *HdrInterceptorProcessor) Save(data process.InterceptedData, _ core.PeerID, topic string) error + func (hip *HdrInterceptorProcessor) Validate(data process.InterceptedData, _ core.PeerID) error + type InterceptedTransactionHandler interface + Fee func() *big.Int + Nonce func() uint64 + ReceiverShardId func() uint32 + SenderAddress func() []byte + SenderShardId func() uint32 + Transaction func() data.TransactionHandler + type MiniblockInterceptorProcessor struct + func NewMiniblockInterceptorProcessor(argument *ArgMiniblockInterceptorProcessor) (*MiniblockInterceptorProcessor, error) + func (mip *MiniblockInterceptorProcessor) IsInterfaceNil() bool + func (mip *MiniblockInterceptorProcessor) RegisterHandler(handler func(topic string, hash []byte, data interface{})) + func (mip *MiniblockInterceptorProcessor) Save(data process.InterceptedData, _ core.PeerID, topic string) error + func (mip *MiniblockInterceptorProcessor) Validate(_ process.InterceptedData, _ core.PeerID) error + type ShardedPool interface + AddData func(key []byte, data interface{}, sizeInBytes int, cacheID string) + type TrieNodeInterceptorProcessor struct + func NewTrieNodesInterceptorProcessor(interceptedNodes storage.Cacher) (*TrieNodeInterceptorProcessor, error) + func (tnip *TrieNodeInterceptorProcessor) IsInterfaceNil() bool + func (tnip *TrieNodeInterceptorProcessor) RegisterHandler(_ func(topic string, hash []byte, data interface{})) + func (tnip *TrieNodeInterceptorProcessor) Save(data process.InterceptedData, _ core.PeerID, _ string) error + func (tnip *TrieNodeInterceptorProcessor) Validate(_ process.InterceptedData, _ core.PeerID) error + type TrieNodesChunksProcessorArgs struct + ChunksCacher storage.Cacher + Hasher hashing.Hasher + RequestHandler process.RequestHandler + RequestInterval time.Duration + Topic string + type TxInterceptorProcessor struct + func NewTxInterceptorProcessor(argument *ArgTxInterceptorProcessor) (*TxInterceptorProcessor, error) + func (txip *TxInterceptorProcessor) IsInterfaceNil() bool + func (txip *TxInterceptorProcessor) RegisterHandler(_ func(topic string, hash []byte, data interface{})) + func (txip *TxInterceptorProcessor) Save(data process.InterceptedData, peerOriginator core.PeerID, _ string) error + func (txip *TxInterceptorProcessor) Validate(data process.InterceptedData, _ core.PeerID) error