Versions in this module Expand all Collapse all v1 v1.999.0 Nov 17, 2022 Changes in this version + const DurationBootstrapingTime + func FloodTheNetwork(peer p2p.Messenger, topic string, isFlooding *atomic.Value, messageSize uint64) + type MessageProcessor struct + FloodPreventer process.FloodPreventer + func CreateTopicsAndMockInterceptors(peers []p2p.Messenger, blacklistHandlers []floodPreventers.QuotaStatusHandler, ...) ([]*MessageProcessor, error) + func (mp *MessageProcessor) IsInterfaceNil() bool + func (mp *MessageProcessor) NumMessagesProcessed() uint32 + func (mp *MessageProcessor) NumMessagesReceived() uint32 + func (mp *MessageProcessor) ProcessReceivedMessage(message p2p.MessageP2P, fromConnectedPeer core.PeerID) error + func (mp *MessageProcessor) SizeMessagesProcessed() uint64 + func (mp *MessageProcessor) SizeMessagesReceived() uint64
Go to main page