discovery

Documentation

Index

• type Discovery
  • func NewDiscovery(net p2p.P2P, maskLst []string, maskFilter p2p.AddressFilter, ...) *Discovery
  • func (self *Discovery) AddrHandle(ctx *p2p.Context, msg *types.Addr)
  • func (self *Discovery) AddrReqHandle(ctx *p2p.Context)
  • func (self *Discovery) FindNodeHandle(ctx *p2p.Context, freq *types.FindNodeReq)
  • func (self *Discovery) FindNodeResponseHandle(ctx *p2p.Context, fresp *types.FindNodeResp)
  • func (self *Discovery) OnAddPeer(info *peer.PeerInfo)
  • func (self *Discovery) OnDelPeer(info *peer.PeerInfo)
  • func (self *Discovery) Start()
  • func (self *Discovery) Stop()

Types

type Discovery

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

func NewDiscovery

func NewDiscovery(net p2p.P2P, maskLst []string, maskFilter p2p.AddressFilter, refleshInterval time.Duration) *Discovery

func (*Discovery) AddrHandle

func (self *Discovery) AddrHandle(ctx *p2p.Context, msg *types.Addr)

func (*Discovery) AddrReqHandle

func (self *Discovery) AddrReqHandle(ctx *p2p.Context)

func (*Discovery) FindNodeHandle

func (self *Discovery) FindNodeHandle(ctx *p2p.Context, freq *types.FindNodeReq)

func (*Discovery) FindNodeResponseHandle

func (self *Discovery) FindNodeResponseHandle(ctx *p2p.Context, fresp *types.FindNodeResp)

func (*Discovery) OnAddPeer

func (self *Discovery) OnAddPeer(info *peer.PeerInfo)

func (*Discovery) OnDelPeer

func (self *Discovery) OnDelPeer(info *peer.PeerInfo)

func (*Discovery) Start

func (self *Discovery) Start()

func (*Discovery) Stop

func (self *Discovery) Stop()