peermgr

Documentation

Index

• Constants
• type MaybePeerMgr
• type NewFilPeer
• 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 MaybePeerMgr

type MaybePeerMgr struct {
	fx.In

	Mgr *PeerMgr `optional:"true"`
}

type NewFilPeer

type NewFilPeer struct {
	Id peer.ID
}

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