monitor

Documentation

Index

• type PeerManager
• type PeerMonitor
  • func NewPeerMonitor(ctx context.Context, l log.Logger, clock clock.Clock, manager PeerManager, ...) *PeerMonitor
  • func (p *PeerMonitor) Start()
  • func (p *PeerMonitor) Stop()

Types

type PeerManager

type PeerManager interface {
	Peers() []peer.ID
	GetPeerScore(id peer.ID) (float64, error)
	IsStatic(peer.ID) bool
	// BanPeer bans the peer until the specified time and disconnects any existing connections.
	BanPeer(peer.ID, time.Time) error
}

type PeerMonitor

type PeerMonitor struct {
	// contains filtered or unexported fields
}

PeerMonitor runs a background process to periodically check for peers with scores below a minimum. When it finds bad peers, it disconnects and bans them. A delay is introduced between each peer being checked to avoid spikes in system load.

func NewPeerMonitor

func NewPeerMonitor(ctx context.Context, l log.Logger, clock clock.Clock, manager PeerManager, minScore float64, banDuration time.Duration) *PeerMonitor

func (*PeerMonitor) Start

func (p *PeerMonitor) Start()

func (*PeerMonitor) Stop

func (p *PeerMonitor) Stop()