Versions in this module Expand all Collapse all v0 v0.0.0 May 17, 2024 Changes in this version + type HeaderInterceptor struct + func NewHeaderInterceptor(marshalizer marshal.Marshalizer, headers storage.Cacher, ...) (*HeaderInterceptor, error) + func (hi *HeaderInterceptor) ProcessReceivedMessage(message p2p.MessageP2P) error + type HeaderInterceptorBase struct + func NewHeaderInterceptorBase(marshalizer marshal.Marshalizer, storer storage.Storer, ...) (*HeaderInterceptorBase, error) + func (hib *HeaderInterceptorBase) CheckHeaderForCurrentShard(interceptedHdr *block.InterceptedHeader) bool + func (hib *HeaderInterceptorBase) ParseReceivedMessage(message p2p.MessageP2P) (*block.InterceptedHeader, error) + type MetachainHeaderInterceptor struct + func NewMetachainHeaderInterceptor(marshalizer marshal.Marshalizer, metachainHeaders storage.Cacher, ...) (*MetachainHeaderInterceptor, error) + func (mhi *MetachainHeaderInterceptor) ProcessReceivedMessage(message p2p.MessageP2P) error + type PeerBlockBodyInterceptor struct + func NewPeerBlockBodyInterceptor(marshalizer marshal.Marshalizer, cache storage.Cacher, storer storage.Storer, ...) (*PeerBlockBodyInterceptor, error) + func (pbbi *PeerBlockBodyInterceptor) ProcessReceivedMessage(message p2p.MessageP2P) error + type TxBlockBodyInterceptor struct + func NewTxBlockBodyInterceptor(marshalizer marshal.Marshalizer, cache storage.Cacher, storer storage.Storer, ...) (*TxBlockBodyInterceptor, error) + func (tbbi *TxBlockBodyInterceptor) ProcessReceivedMessage(message p2p.MessageP2P) error