networkinfo

Documentation

Index

• Variables
• type Service
  • func MustNew(h p2p.Host, rendezvous nodeconfig.GroupID, peerChan chan p2p.Peer, ...) *Service
  • func New(h p2p.Host, rendezvous nodeconfig.GroupID, peerChan chan p2p.Peer, ...) (*Service, error)
  • func (s *Service) APIs() []rpc.API
  • func (s *Service) DoService()
  • func (s *Service) Init() error
  • func (s *Service) NotifyService(params map[string]interface{})
  • func (s *Service) Run()
  • func (s *Service) SetMessageChan(messageChan chan *msg_pb.Message)
  • func (s *Service) StartService()
  • func (s *Service) StopService()

Variables

var (
	// retry for 30s and give up then
	ConnectionRetry = 15
)

ConnectionRetry set the number of retry of connection to bootnode in case the initial connection is failed

Types

type Service

type Service struct {
	Host       p2p.Host
	Rendezvous nodeconfig.GroupID
	// contains filtered or unexported fields
}

Service is the network info service.

func MustNew

func MustNew(
	h p2p.Host, rendezvous nodeconfig.GroupID, peerChan chan p2p.Peer,
	bootnodes p2putils.AddrList, dataStorePath string,
) *Service

MustNew is a panic-on-error version of New.

func New

func New(
	h p2p.Host, rendezvous nodeconfig.GroupID, peerChan chan p2p.Peer,
	bootnodes p2putils.AddrList, dataStorePath string,
) (*Service, error)

New returns role conversion service. If dataStorePath is not empty, it points to a persistent database directory to use.

func (*Service) APIs

func (s *Service) APIs() []rpc.API

APIs for the services.

func (*Service) DoService

func (s *Service) DoService()

DoService does network info.

func (*Service) Init

func (s *Service) Init() error

Init initializes role conversion service.

func (*Service) NotifyService

func (s *Service) NotifyService(params map[string]interface{})

NotifyService notify service

func (*Service) Run

func (s *Service) Run()

Run runs network info.

func (*Service) SetMessageChan

func (s *Service) SetMessageChan(messageChan chan *msg_pb.Message)

SetMessageChan sets up message channel to service.

func (*Service) StartService

func (s *Service) StartService()

StartService starts network info service.

func (*Service) StopService

func (s *Service) StopService()

StopService stops network info service.