peermgr

Documentation

Index

• Constants
• type FilPeerEvt
• type FilPeerEvtType
• type MaybePeerMgr
• type PeerMgr
  • func NewPeerMgr(lc fx.Lifecycle, h host.Host, dht *dht.IpfsDHT, ...) (*PeerMgr, error)
  • func (pmgr *PeerMgr) AddFilecoinPeer(p peer.ID)
  • func (pmgr *PeerMgr) Disconnect(p peer.ID)
  • func (pmgr *PeerMgr) GetPeerLatency(p peer.ID) (time.Duration, bool)
  • func (pmgr *PeerMgr) Run(ctx context.Context)
  • func (pmgr *PeerMgr) SetPeerLatency(p peer.ID, latency time.Duration)
  • func (pmgr *PeerMgr) Stop(ctx context.Context) error

Constants

const (
	MaxFilPeers = 32
	MinFilPeers = 12
)

Types

type FilPeerEvt

type FilPeerEvt struct {
	Type FilPeerEvtType
	ID   peer.ID
}

type FilPeerEvtType

type FilPeerEvtType int

const (
	AddFilPeerEvt FilPeerEvtType = iota
	RemoveFilPeerEvt
)

type MaybePeerMgr

type MaybePeerMgr struct {
	fx.In

	Mgr *PeerMgr `optional:"true"`
}

type PeerMgr

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

func NewPeerMgr

func NewPeerMgr(lc fx.Lifecycle, h host.Host, dht *dht.IpfsDHT, bootstrap dtypes.BootstrapPeers) (*PeerMgr, error)

func (*PeerMgr) AddFilecoinPeer

func (pmgr *PeerMgr) AddFilecoinPeer(p peer.ID)

func (*PeerMgr) Disconnect

func (pmgr *PeerMgr) Disconnect(p peer.ID)

func (*PeerMgr) GetPeerLatency

func (pmgr *PeerMgr) GetPeerLatency(p peer.ID) (time.Duration, bool)

func (*PeerMgr) Run

func (pmgr *PeerMgr) Run(ctx context.Context)

func (*PeerMgr) SetPeerLatency

func (pmgr *PeerMgr) SetPeerLatency(p peer.ID, latency time.Duration)

func (*PeerMgr) Stop

func (pmgr *PeerMgr) Stop(ctx context.Context) error