monitor

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(ctx context.Context, l log.Logger, clock clock.Clock, manager PeerManager, minScore float64, banDuration time.Duration) *PeerMonitor

func (p *PeerMonitor) Start()

func (p *PeerMonitor) Stop()