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 + 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