Versions in this module Expand all Collapse all v1 v1.1.66 Jun 17, 2021 v1.1.65 Jun 17, 2021 Changes in this version + type ArgHdrInterceptorProcessor struct + BlockBlackList process.TimeCacher + HdrValidator process.HeaderValidator + Headers dataRetriever.HeadersPool + type ArgMiniblockInterceptorProcessor struct + Hasher hashing.Hasher + Marshalizer marshal.Marshalizer + MiniblockCache storage.Cacher + ShardCoordinator sharding.Coordinator + WhiteListHandler process.WhiteListHandler + 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 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, _ core.PeerID, _ string) error + func (txip *TxInterceptorProcessor) Validate(data process.InterceptedData, _ core.PeerID) error