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 NewNilTopicFloodPreventer() *nilTopicFloodPreventer + type AntiFlood struct + func (af *AntiFlood) ApplyConsensusSize(_ int) + func (af *AntiFlood) BlacklistPeer(_ core.PeerID, _ string, _ time.Duration) + func (af *AntiFlood) CanProcessMessage(_ p2p.MessageP2P, _ core.PeerID) error + func (af *AntiFlood) CanProcessMessagesOnTopic(_ core.PeerID, _ string, _ uint32, _ uint64, _ []byte) error + func (af *AntiFlood) IsInterfaceNil() bool + func (af *AntiFlood) IsOriginatorEligibleForTopic(_ core.PeerID, _ string) error + func (af *AntiFlood) ResetForTopic(_ string) + func (af *AntiFlood) SetDebugger(_ process.AntifloodDebugger) error + func (af *AntiFlood) SetMaxMessagesForTopic(_ string, _ uint32) + func (af *AntiFlood) SetPeerValidatorMapper(_ process.PeerValidatorMapper) error + func (af *AntiFlood) SetTopicsForAll(_ ...string) + type AntifloodDebugger struct + func (ad *AntifloodDebugger) AddData(_ core.PeerID, _ string, _ uint32, _ uint64, _ []byte, _ bool) + func (ad *AntifloodDebugger) Close() error + func (ad *AntifloodDebugger) IsInterfaceNil() bool + type PeerBlacklistCacher struct + func (pbc *PeerBlacklistCacher) Has(_ core.PeerID) bool + func (pbc *PeerBlacklistCacher) IsInterfaceNil() bool + func (pbc *PeerBlacklistCacher) Sweep() + func (pbc *PeerBlacklistCacher) Upsert(_ core.PeerID, _ time.Duration) error + type PeerValidatorMapper struct + func (p *PeerValidatorMapper) GetPeerInfo(_ core.PeerID) core.P2PPeerInfo + func (p *PeerValidatorMapper) IsInterfaceNil() bool + type TimeCache struct + func (tc *TimeCache) Add(_ string) error + func (tc *TimeCache) Has(_ string) bool + func (tc *TimeCache) IsInterfaceNil() bool + func (tc *TimeCache) Sweep() + func (tc *TimeCache) Upsert(_ string, _ time.Duration) error