disabled

Documentation

Index

• func NewNilTopicFloodPreventer() *nilTopicFloodPreventer
• type AntiFlood
  • func (af *AntiFlood) ApplyConsensusSize(_ int)
  • func (af *AntiFlood) CanProcessMessage(_ p2p.MessageP2P, _ core.PeerID) error
  • func (af *AntiFlood) CanProcessMessagesOnTopic(_ core.PeerID, _ string, _ uint32, _ uint64) error
  • func (af *AntiFlood) IsInterfaceNil() bool
  • func (af *AntiFlood) ResetForTopic(_ string)
  • func (af *AntiFlood) SetDebugger(_ process.AntifloodDebugger) error
  • func (af *AntiFlood) SetMaxMessagesForTopic(_ string, _ uint32)
• type AntifloodDebugger
  • func (ad *AntifloodDebugger) AddData(_ core.PeerID, _ string, _ uint32, _ uint64, _ bool)
  • func (ad *AntifloodDebugger) Close() error
  • func (ad *AntifloodDebugger) IsInterfaceNil() bool
• type PeerBlacklistHandler
  • func (pdbh *PeerBlacklistHandler) Add(_ core.PeerID) error
  • func (pdbh *PeerBlacklistHandler) AddWithSpan(_ core.PeerID, _ time.Duration) error
  • func (pdbh *PeerBlacklistHandler) Has(_ core.PeerID) bool
  • func (pdbh *PeerBlacklistHandler) IsInterfaceNil() bool
  • func (pdbh *PeerBlacklistHandler) Sweep()

Functions

func NewNilTopicFloodPreventer

func NewNilTopicFloodPreventer() *nilTopicFloodPreventer

NewNilTopicFloodPreventer returns a new instance of nilTopicFloodPreventer

Types

type AntiFlood

type AntiFlood struct {
}

AntiFlood is a mock implementation of the antiflood interface

func (*AntiFlood) ApplyConsensusSize

func (af *AntiFlood) ApplyConsensusSize(_ int)

ApplyConsensusSize does nothing

func (*AntiFlood) CanProcessMessage

func (af *AntiFlood) CanProcessMessage(_ p2p.MessageP2P, _ core.PeerID) error

CanProcessMessage will always return nil

func (*AntiFlood) CanProcessMessagesOnTopic

func (af *AntiFlood) CanProcessMessagesOnTopic(_ core.PeerID, _ string, _ uint32, _ uint64) error

CanProcessMessagesOnTopic will always return nil

func (*AntiFlood) IsInterfaceNil

func (af *AntiFlood) IsInterfaceNil() bool

IsInterfaceNil return true if there is no value under the interface

func (*AntiFlood) ResetForTopic

func (af *AntiFlood) ResetForTopic(_ string)

ResetForTopic won't do anything

func (*AntiFlood) SetDebugger

func (af *AntiFlood) SetDebugger(_ process.AntifloodDebugger) error

SetDebugger returns nil

func (*AntiFlood) SetMaxMessagesForTopic

func (af *AntiFlood) SetMaxMessagesForTopic(_ string, _ uint32)

SetMaxMessagesForTopic won't do anything

type AntifloodDebugger

type AntifloodDebugger struct {
}

AntifloodDebugger is a disabled instance of the antoiflood debugger

func (*AntifloodDebugger) AddData

func (ad *AntifloodDebugger) AddData(_ core.PeerID, _ string, _ uint32, _ uint64, _ bool)

AddData does nothing

func (*AntifloodDebugger) Close

func (ad *AntifloodDebugger) Close() error

Close returns nil

func (*AntifloodDebugger) IsInterfaceNil

func (ad *AntifloodDebugger) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

type PeerBlacklistHandler

type PeerBlacklistHandler struct {
}

PeerBlacklistHandler is a mock implementation of PeerBlacklistHandler that does not manage black listed keys (all keys [peers] are whitelisted)

func (*PeerBlacklistHandler) Add

func (pdbh *PeerBlacklistHandler) Add(_ core.PeerID) error

Add does nothing

func (*PeerBlacklistHandler) AddWithSpan

func (pdbh *PeerBlacklistHandler) AddWithSpan(_ core.PeerID, _ time.Duration) error

AddWithSpan does nothing

func (*PeerBlacklistHandler) Has

func (pdbh *PeerBlacklistHandler) Has(_ core.PeerID) bool

Has outputs false (all peers are white listed)

func (*PeerBlacklistHandler) IsInterfaceNil

func (pdbh *PeerBlacklistHandler) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*PeerBlacklistHandler) Sweep

func (pdbh *PeerBlacklistHandler) Sweep()

Sweep does nothing