peermgr

Documentation

Index

• Constants
• type IPeerMgr
• type MockPeerMgr
  • func (m MockPeerMgr) AddFilecoinPeer(p peer.ID)
  • func (m MockPeerMgr) Disconnect(p peer.ID)
  • func (m MockPeerMgr) GetPeerLatency(p peer.ID) (time.Duration, bool)
  • func (m MockPeerMgr) Run(ctx context.Context)
  • func (m MockPeerMgr) SetPeerLatency(p peer.ID, latency time.Duration)
  • func (m MockPeerMgr) Stop(ctx context.Context) error
• type NewFilPeer
• type PeerMgr
  • func NewPeerMgr(h host.Host, dht *dht.IpfsDHT, period time.Duration, bootstrap []peer.AddrInfo) (*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 = 320
	MinFilPeers = 128
)

Types

type IPeerMgr

type IPeerMgr interface {
	AddFilecoinPeer(p peer.ID)
	GetPeerLatency(p peer.ID) (time.Duration, bool)
	SetPeerLatency(p peer.ID, latency time.Duration)
	Disconnect(p peer.ID)
	Stop(ctx context.Context) error
	Run(ctx context.Context)
}

type MockPeerMgr

type MockPeerMgr struct {
}

func (MockPeerMgr) AddFilecoinPeer

func (m MockPeerMgr) AddFilecoinPeer(p peer.ID)

func (MockPeerMgr) Disconnect

func (m MockPeerMgr) Disconnect(p peer.ID)

func (MockPeerMgr) GetPeerLatency

func (m MockPeerMgr) GetPeerLatency(p peer.ID) (time.Duration, bool)

func (MockPeerMgr) Run

func (m MockPeerMgr) Run(ctx context.Context)

func (MockPeerMgr) SetPeerLatency

func (m MockPeerMgr) SetPeerLatency(p peer.ID, latency time.Duration)

func (MockPeerMgr) Stop

func (m MockPeerMgr) Stop(ctx context.Context) error

type NewFilPeer

type NewFilPeer struct {
	Id peer.ID //nolint
}

type PeerMgr

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

func NewPeerMgr

func NewPeerMgr(h host.Host, dht *dht.IpfsDHT, period time.Duration, bootstrap []peer.AddrInfo) (*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