test

Documentation

Index

• type NetworkManager
  • func NewNetworkManager() *NetworkManager
  • func (nm *NetworkManager) GetPeers() []module.PeerID
  • func (nm *NetworkManager) Join(nm2 *NetworkManager)
  • func (nm *NetworkManager) RegisterReactor(name string, pi module.ProtocolInfo, reactor module.Reactor, ...) (module.ProtocolHandler, error)
  • func (nm *NetworkManager) RegisterReactorForStreams(name string, pi module.ProtocolInfo, reactor module.Reactor, ...) (module.ProtocolHandler, error)

Types

type NetworkManager

type NetworkManager struct {
	test.NetworkManagerBase

	ID module.PeerID
	// contains filtered or unexported fields
}

func NewNetworkManager

func NewNetworkManager() *NetworkManager

func (*NetworkManager) GetPeers

func (nm *NetworkManager) GetPeers() []module.PeerID

func (*NetworkManager) Join

func (nm *NetworkManager) Join(nm2 *NetworkManager)

func (*NetworkManager) RegisterReactor

func (nm *NetworkManager) RegisterReactor(name string, pi module.ProtocolInfo, reactor module.Reactor, piList []module.ProtocolInfo, priority uint8) (module.ProtocolHandler, error)

func (*NetworkManager) RegisterReactorForStreams

func (nm *NetworkManager) RegisterReactorForStreams(name string, pi module.ProtocolInfo, reactor module.Reactor, piList []module.ProtocolInfo, priority uint8) (module.ProtocolHandler, error)