Versions in this module Expand all Collapse all v0 v0.0.2 Oct 31, 2023 v0.0.1 Oct 30, 2023 Changes in this version + func NewWhiteListDataVerifier(cacher storage.Cacher) (*whiteListDataVerifier, error) + type MultiDataInterceptor struct + func NewMultiDataInterceptor(topic string, marshalizer marshal.Marshalizer, ...) (*MultiDataInterceptor, 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) SetInterceptedDebugHandler(handler process.InterceptedDebugger) error + type SingleDataInterceptor struct + func NewSingleDataInterceptor(topic string, factory process.InterceptedDataFactory, ...) (*SingleDataInterceptor, 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{})) + func (sdi *SingleDataInterceptor) SetInterceptedDebugHandler(handler process.InterceptedDebugger) error
Go to main page