Affected by 
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewWhiteListDataVerifier ¶ added in v1.0.102
NewWhiteListDataVerifier returns a default data verifier
Types ¶
type MultiDataInterceptor ¶
type MultiDataInterceptor struct {
// contains filtered or unexported fields
}
MultiDataInterceptor is used for intercepting packed multi data
func NewMultiDataInterceptor ¶
func NewMultiDataInterceptor( topic string, marshalizer marshal.Marshalizer, factory process.InterceptedDataFactory, processor process.InterceptorProcessor, throttler process.InterceptorThrottler, antifloodHandler process.P2PAntifloodHandler, whiteListHandler process.WhiteListHandler, ) (*MultiDataInterceptor, error)
NewMultiDataInterceptor hooks a new interceptor for packed multi data
func (*MultiDataInterceptor) IsInterfaceNil ¶
func (mdi *MultiDataInterceptor) IsInterfaceNil() bool
IsInterfaceNil returns true if there is no value under the interface
func (*MultiDataInterceptor) ProcessReceivedMessage ¶
func (mdi *MultiDataInterceptor) ProcessReceivedMessage(message p2p.MessageP2P, fromConnectedPeer p2p.PeerID) error
ProcessReceivedMessage is the callback func from the p2p.Messenger and will be called each time a new message was received (for the topic this validator was registered to)
type SingleDataInterceptor ¶
type SingleDataInterceptor struct {
// contains filtered or unexported fields
}
SingleDataInterceptor is used for intercepting packed multi data
func NewSingleDataInterceptor ¶
func NewSingleDataInterceptor( topic string, factory process.InterceptedDataFactory, processor process.InterceptorProcessor, throttler process.InterceptorThrottler, antifloodHandler process.P2PAntifloodHandler, whiteListHandler process.WhiteListHandler, ) (*SingleDataInterceptor, error)
NewSingleDataInterceptor hooks a new interceptor for single data
func (*SingleDataInterceptor) IsInterfaceNil ¶
func (sdi *SingleDataInterceptor) IsInterfaceNil() bool
IsInterfaceNil returns true if there is no value under the interface
func (*SingleDataInterceptor) ProcessReceivedMessage ¶
func (sdi *SingleDataInterceptor) ProcessReceivedMessage(message p2p.MessageP2P, fromConnectedPeer p2p.PeerID) error
ProcessReceivedMessage is the callback func from the p2p.Messenger and will be called each time a new message was received (for the topic this validator was registered to)
Source Files
Directories