peers

Documentation

Index

• Constants
• type Item
  • func (i *Item) Add(n int) int
  • func (i *Item) Id() peer.ID
  • func (i *Item) Score() int
  • func (i *Item) String() string
• type PeeredObject
• type Pool
  • func NewPool() *Pool
  • func (p *Pool) AddPeer(pid peer.ID)
  • func (p *Pool) BanStatus(pid peer.ID) bool
  • func (p *Pool) LenBannedPeers() int
  • func (p *Pool) RemovePeer(pid peer.ID)
  • func (p *Pool) Request() (pid *Item, done func(), err error)
  • func (p *Pool) SetBanStatus(pid peer.ID, banned bool)

Constants

const (
	MaxBadResponses = 50
)

Types

type Item

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

Item is an item in the pool

func (*Item) Add

func (i *Item) Add(n int) int

func (*Item) Id

func (i *Item) Id() peer.ID

func (*Item) Score

func (i *Item) Score() int

func (*Item) String

func (i *Item) String() string

type PeeredObject

type PeeredObject[T any] struct {
	Peer string
	Data T
}

type Pool

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

PeerPool is a pool of peers

func NewPool

func NewPool() *Pool

func (*Pool) AddPeer

func (p *Pool) AddPeer(pid peer.ID)

func (*Pool) BanStatus

func (p *Pool) BanStatus(pid peer.ID) bool

func (*Pool) LenBannedPeers

func (p *Pool) LenBannedPeers() int

func (*Pool) RemovePeer

func (p *Pool) RemovePeer(pid peer.ID)

func (*Pool) Request

func (p *Pool) Request() (pid *Item, done func(), err error)

Request a peer from the pool caller MUST call the done function when done with peer IFF err != nil

func (*Pool) SetBanStatus

func (p *Pool) SetBanStatus(pid peer.ID, banned bool)