pgmanager

Documentation

Index

• Constants
• type PeerGroupManager
  • func NewPeerGroupManager(peers []peer.ID) *PeerGroupManager
  • func (pm *PeerGroupManager) Close()
  • func (pm *PeerGroupManager) GetPeerCount() int
  • func (pm *PeerGroupManager) GetPeerInfo(peerId peer.ID) *PeerInfo
  • func (pm *PeerGroupManager) GetPeerInfoList() PeerInfos
  • func (pm *PeerGroupManager) GetPeerTimeout() int64
  • func (pm *PeerGroupManager) HasIdlePeer() bool
  • func (pm *PeerGroupManager) IsAllIdle() bool
  • func (pm *PeerGroupManager) IsBestPeer(p peer.ID) bool
  • func (pm *PeerGroupManager) LockPeer(peerId peer.ID) bool
  • func (pm *PeerGroupManager) RegisterIdleCallback(callback func())
  • func (pm *PeerGroupManager) ReleasePeer(peerId peer.ID)
  • func (pm *PeerGroupManager) ReleasePeers(ids []peer.ID)
  • func (pm *PeerGroupManager) SleepPeer(peerId peer.ID)
  • func (pm *PeerGroupManager) UpdateSpeed(peerId peer.ID, transformSpeed int64)
  • func (pm *PeerGroupManager) UpdateTTFB(peerId peer.ID, ttfb int64)
  • func (pm *PeerGroupManager) WaitIdlePeers(ctx context.Context, top int) []peer.ID
• type PeerInfo
  • func (pi PeerInfo) String() string
• type PeerInfos
  • func (p PeerInfos) Len() int
  • func (p PeerInfos) Less(i, j int) bool
  • func (p PeerInfos) Swap(i, j int)

Constants

const SmoothFactor = 1.5

Types

type PeerGroupManager

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

func NewPeerGroupManager

func NewPeerGroupManager(peers []peer.ID) *PeerGroupManager

func (*PeerGroupManager) Close

func (pm *PeerGroupManager) Close()

func (*PeerGroupManager) GetPeerCount

func (pm *PeerGroupManager) GetPeerCount() int

func (*PeerGroupManager) GetPeerInfo

func (pm *PeerGroupManager) GetPeerInfo(peerId peer.ID) *PeerInfo

func (*PeerGroupManager) GetPeerInfoList

func (pm *PeerGroupManager) GetPeerInfoList() PeerInfos

func (*PeerGroupManager) GetPeerTimeout

func (pm *PeerGroupManager) GetPeerTimeout() int64

func (*PeerGroupManager) HasIdlePeer

func (pm *PeerGroupManager) HasIdlePeer() bool

func (*PeerGroupManager) IsAllIdle

func (pm *PeerGroupManager) IsAllIdle() bool

func (*PeerGroupManager) IsBestPeer

func (pm *PeerGroupManager) IsBestPeer(p peer.ID) bool

func (*PeerGroupManager) LockPeer

func (pm *PeerGroupManager) LockPeer(peerId peer.ID) bool

func (*PeerGroupManager) RegisterIdleCallback

func (pm *PeerGroupManager) RegisterIdleCallback(callback func())

func (*PeerGroupManager) ReleasePeer

func (pm *PeerGroupManager) ReleasePeer(peerId peer.ID)

func (*PeerGroupManager) ReleasePeers

func (pm *PeerGroupManager) ReleasePeers(ids []peer.ID)

func (*PeerGroupManager) SleepPeer

func (pm *PeerGroupManager) SleepPeer(peerId peer.ID)

func (*PeerGroupManager) UpdateSpeed

func (pm *PeerGroupManager) UpdateSpeed(peerId peer.ID, transformSpeed int64)

func (*PeerGroupManager) UpdateTTFB

func (pm *PeerGroupManager) UpdateTTFB(peerId peer.ID, ttfb int64)

func (*PeerGroupManager) WaitIdlePeers

func (pm *PeerGroupManager) WaitIdlePeers(ctx context.Context, top int) []peer.ID

type PeerInfo

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

func (PeerInfo) String

func (pi PeerInfo) String() string

type PeerInfos

type PeerInfos []*PeerInfo

func (PeerInfos) Len

func (p PeerInfos) Len() int

func (PeerInfos) Less

func (p PeerInfos) Less(i, j int) bool

ttfb first

func (PeerInfos) Swap

func (p PeerInfos) Swap(i, j int)