reconnect

Documentation

Index

• Constants
• type ReconnectPeerInfo
• type ReconnectService
  • func NewReconectService(net p2p.P2P, staticReserveFilter p2p.AddressFilter) *ReconnectService
  • func (self *ReconnectService) OnAddPeer(p *peer.PeerInfo)
  • func (self *ReconnectService) OnDelPeer(p *peer.PeerInfo)
  • func (self *ReconnectService) ReconnectCount() int
  • func (self *ReconnectService) Start()
  • func (self *ReconnectService) Stop()

Constants

const MaxRetryCountForReserveNode = 100

Types

type ReconnectPeerInfo

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

type ReconnectService

type ReconnectService struct {
	sync.RWMutex
	MaxRetryCount int
	RetryAddrs    map[string]*ReconnectPeerInfo
	// contains filtered or unexported fields
}

ReconnectService contain addr need to reconnect

func NewReconectService

func NewReconectService(net p2p.P2P, staticReserveFilter p2p.AddressFilter) *ReconnectService

func (*ReconnectService) OnAddPeer

func (self *ReconnectService) OnAddPeer(p *peer.PeerInfo)

func (*ReconnectService) OnDelPeer

func (self *ReconnectService) OnDelPeer(p *peer.PeerInfo)

func (*ReconnectService) ReconnectCount

func (self *ReconnectService) ReconnectCount() int

func (*ReconnectService) Start

func (self *ReconnectService) Start()

func (*ReconnectService) Stop

func (self *ReconnectService) Stop()