Versions in this module Expand all Collapse all v0 v0.0.1 Nov 7, 2024 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) + func NewValidatorInfoInterceptorProcessor(args ArgValidatorInfoInterceptorProcessor) (*validatorInfoInterceptorProcessor, 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 ArgValidatorInfoInterceptorProcessor struct + ValidatorInfoPool dataRetriever.ShardedDataCacherNotifier + 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 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 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
Go to main page