Versions in this module Expand all Collapse all v1 v1.999.0 Nov 17, 2022 Changes in this version + func NewEpochStartMetaBlockInterceptor(args ArgsEpochStartMetaBlockInterceptor) (*epochStartMetaBlockInterceptor, error) + func NewWhiteListDataVerifier(cacher storage.Cacher) (*whiteListDataVerifier, error) + type ArgMultiDataInterceptor struct + AntifloodHandler process.P2PAntifloodHandler + CurrentPeerId core.PeerID + DataFactory process.InterceptedDataFactory + Marshalizer marshal.Marshalizer + PreferredPeersHolder process.PreferredPeersHolderHandler + Processor process.InterceptorProcessor + Throttler process.InterceptorThrottler + Topic string + WhiteListRequest process.WhiteListHandler + type ArgSingleDataInterceptor struct + AntifloodHandler process.P2PAntifloodHandler + CurrentPeerId core.PeerID + DataFactory process.InterceptedDataFactory + PreferredPeersHolder process.PreferredPeersHolderHandler + Processor process.InterceptorProcessor + Throttler process.InterceptorThrottler + Topic string + WhiteListRequest process.WhiteListHandler + type ArgsEpochStartMetaBlockInterceptor struct + ConsensusPercentage int + Hasher hashing.Hasher + Marshalizer marshal.Marshalizer + NumConnectedPeersProvider process.NumConnectedPeersProvider + type MultiDataInterceptor struct + func NewMultiDataInterceptor(arg ArgMultiDataInterceptor) (*MultiDataInterceptor, error) + func (bdi MultiDataInterceptor) SetInterceptedDebugHandler(handler process.InterceptedDebugger) error + func (mdi *MultiDataInterceptor) Close() error + func (mdi *MultiDataInterceptor) IsInterfaceNil() bool + func (mdi *MultiDataInterceptor) ProcessReceivedMessage(message p2p.MessageP2P, fromConnectedPeer core.PeerID) error + func (mdi *MultiDataInterceptor) RegisterHandler(handler func(topic string, hash []byte, data interface{})) + func (mdi *MultiDataInterceptor) SetChunkProcessor(processor process.InterceptedChunksProcessor) error + type SingleDataInterceptor struct + func NewSingleDataInterceptor(arg ArgSingleDataInterceptor) (*SingleDataInterceptor, error) + func (bdi SingleDataInterceptor) SetInterceptedDebugHandler(handler process.InterceptedDebugger) error + func (sdi *SingleDataInterceptor) Close() error + func (sdi *SingleDataInterceptor) IsInterfaceNil() bool + func (sdi *SingleDataInterceptor) ProcessReceivedMessage(message p2p.MessageP2P, fromConnectedPeer core.PeerID) error + func (sdi *SingleDataInterceptor) RegisterHandler(handler func(topic string, hash []byte, data interface{}))