peermgr

Documentation

Index

• Constants
• type FilPeerEvt
• type FilPeerEvtType
• 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 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 FilPeerEvt

type FilPeerEvt struct {
	Type FilPeerEvtType
	ID   peer.ID
}

type FilPeerEvtType

type FilPeerEvtType int

const (
	AddFilPeerEvt FilPeerEvtType = iota
	RemoveFilPeerEvt
)

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 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