peerset

Documentation

Index

• type PeerSet
  • func NewPeerSet(sessionTimeout time.Duration) *PeerSet
  • func (ps *PeerSet) GetPeer(pid peer.ID) *peer.Peer
  • func (ps *PeerSet) GetPeerStatus(pid peer.ID) status.Status
  • func (ps *PeerSet) GetRandomPeer() *peer.Peer
  • func (ps *PeerSet) HasAnyOpenSession() bool
  • func (ps *PeerSet) HasOpenSession(pid peer.ID) bool
  • func (ps *PeerSet) IteratePeers(consumer func(p *peer.Peer) (stop bool))
  • func (ps *PeerSet) Len() int
  • func (ps *PeerSet) Metric() metric.Metric
  • func (ps *PeerSet) NumberOfSessions() int
  • func (ps *PeerSet) OpenSession(pid peer.ID, from, count uint32) int
  • func (ps *PeerSet) RemoveAllSessions()
  • func (ps *PeerSet) RemovePeer(pid peer.ID)
  • func (ps *PeerSet) SessionStats() session.Stats
  • func (ps *PeerSet) Sessions() []*session.Session
  • func (ps *PeerSet) SetExpiredSessionsAsUncompleted()
  • func (ps *PeerSet) SetSessionCompleted(sid int)
  • func (ps *PeerSet) SetSessionUncompleted(sid int)
  • func (ps *PeerSet) StartedAt() time.Time
  • func (ps *PeerSet) TotalSentBundles() int
  • func (ps *PeerSet) UpdateAddress(pid peer.ID, addr, direction string)
  • func (ps *PeerSet) UpdateHeight(pid peer.ID, height uint32, lastBlockHash hash.Hash)
  • func (ps *PeerSet) UpdateInfo(pid peer.ID, moniker string, agent string, consKeys []*bls.PublicKey, ...)
  • func (ps *PeerSet) UpdateInvalidMetric(pid peer.ID, bytes int64)
  • func (ps *PeerSet) UpdateLastReceived(pid peer.ID)
  • func (ps *PeerSet) UpdateLastSent(pid peer.ID)
  • func (ps *PeerSet) UpdateProtocols(pid peer.ID, protocols []string)
  • func (ps *PeerSet) UpdateReceivedMetric(pid peer.ID, msgType message.Type, bytes int64)
  • func (ps *PeerSet) UpdateSentMetric(pid *peer.ID, msgType message.Type, bytes int64)
  • func (ps *PeerSet) UpdateSessionLastActivity(sid int)
  • func (ps *PeerSet) UpdateStatus(pid peer.ID, status status.Status)

Types

type PeerSet

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

func NewPeerSet

func NewPeerSet(sessionTimeout time.Duration) *PeerSet

NewPeerSet constructs a new PeerSet for managing peer information.

func (*PeerSet) GetPeer

func (ps *PeerSet) GetPeer(pid peer.ID) *peer.Peer

GetPeer finds a peer by id and returns a copy of the peer object.

func (*PeerSet) GetPeerStatus

func (ps *PeerSet) GetPeerStatus(pid peer.ID) status.Status

GetPeerStatus finds a peer by id and returns the status of the Peer.

func (*PeerSet) GetRandomPeer

func (ps *PeerSet) GetRandomPeer() *peer.Peer

GetRandomPeer selects a random peer from the peer set based on their download score. Peers with higher score are more likely to be selected.

func (*PeerSet) HasAnyOpenSession

func (ps *PeerSet) HasAnyOpenSession() bool

func (*PeerSet) HasOpenSession

func (ps *PeerSet) HasOpenSession(pid peer.ID) bool

HasOpenSession checks if the specified peer has an open session for downloading blocks. Note that a peer may have more than one session.

func (*PeerSet) IteratePeers

func (ps *PeerSet) IteratePeers(consumer func(p *peer.Peer) (stop bool))

func (*PeerSet) Len

func (ps *PeerSet) Len() int

func (*PeerSet) Metric

func (ps *PeerSet) Metric() metric.Metric

func (*PeerSet) NumberOfSessions

func (ps *PeerSet) NumberOfSessions() int

NumberOfSessions returns the total number of sessions.

func (*PeerSet) OpenSession

func (ps *PeerSet) OpenSession(pid peer.ID, from, count uint32) int

OpenSession opens a new session for downloading blocks and returns the session ID.

func (*PeerSet) RemoveAllSessions

func (ps *PeerSet) RemoveAllSessions()

func (*PeerSet) RemovePeer

func (ps *PeerSet) RemovePeer(pid peer.ID)

func (*PeerSet) SessionStats

func (ps *PeerSet) SessionStats() session.Stats

func (*PeerSet) Sessions

func (ps *PeerSet) Sessions() []*session.Session

func (*PeerSet) SetExpiredSessionsAsUncompleted

func (ps *PeerSet) SetExpiredSessionsAsUncompleted()

func (*PeerSet) SetSessionCompleted

func (ps *PeerSet) SetSessionCompleted(sid int)

func (*PeerSet) SetSessionUncompleted

func (ps *PeerSet) SetSessionUncompleted(sid int)

func (*PeerSet) StartedAt

func (ps *PeerSet) StartedAt() time.Time

func (*PeerSet) TotalSentBundles

func (ps *PeerSet) TotalSentBundles() int

func (*PeerSet) UpdateAddress

func (ps *PeerSet) UpdateAddress(pid peer.ID, addr, direction string)

func (*PeerSet) UpdateHeight

func (ps *PeerSet) UpdateHeight(pid peer.ID, height uint32, lastBlockHash hash.Hash)

func (*PeerSet) UpdateInfo

func (ps *PeerSet) UpdateInfo(
	pid peer.ID,
	moniker string,
	agent string,
	consKeys []*bls.PublicKey,
	services service.Services,
)

func (*PeerSet) UpdateInvalidMetric

func (ps *PeerSet) UpdateInvalidMetric(pid peer.ID, bytes int64)

func (*PeerSet) UpdateLastReceived

func (ps *PeerSet) UpdateLastReceived(pid peer.ID)

func (*PeerSet) UpdateLastSent

func (ps *PeerSet) UpdateLastSent(pid peer.ID)

func (*PeerSet) UpdateProtocols

func (ps *PeerSet) UpdateProtocols(pid peer.ID, protocols []string)

func (*PeerSet) UpdateReceivedMetric

func (ps *PeerSet) UpdateReceivedMetric(pid peer.ID, msgType message.Type, bytes int64)

func (*PeerSet) UpdateSentMetric

func (ps *PeerSet) UpdateSentMetric(pid *peer.ID, msgType message.Type, bytes int64)

func (*PeerSet) UpdateSessionLastActivity

func (ps *PeerSet) UpdateSessionLastActivity(sid int)

func (*PeerSet) UpdateStatus

func (ps *PeerSet) UpdateStatus(pid peer.ID, status status.Status)