net

Documentation

Index

• type NodeConnections
  • func NewNodeConnections(t *testing.T) NodeConnections
  • func (c *NodeConnections) Close()
  • func (c *NodeConnections) SendToEachNode(t *testing.T, m proto.Message)
• type OutgoingPeer
  • func NewConnection(declAddr proto.TCPAddr, address string, ver proto.Version, wavesNetwork string) (*OutgoingPeer, error)
  • func (a *OutgoingPeer) Close() error
  • func (a *OutgoingPeer) SendMessage(m proto.Message) error

Types

type NodeConnections

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

func NewNodeConnections

func NewNodeConnections(t *testing.T) NodeConnections

func (*NodeConnections) Close

func (c *NodeConnections) Close()

func (*NodeConnections) SendToEachNode

func (c *NodeConnections) SendToEachNode(t *testing.T, m proto.Message)

type OutgoingPeer

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

func NewConnection

func NewConnection(declAddr proto.TCPAddr, address string, ver proto.Version, wavesNetwork string) (*OutgoingPeer, error)

func (*OutgoingPeer) Close

func (a *OutgoingPeer) Close() error

func (*OutgoingPeer) SendMessage

func (a *OutgoingPeer) SendMessage(m proto.Message) error