net

Documentation

Index

• type NodeConnections
  • func NewNodeConnections(p *d.Ports) (NodeConnections, error)
  • func (c *NodeConnections) Close(t *testing.T)
  • func (c *NodeConnections) SendToNodes(t *testing.T, m proto.Message, scala bool)
• type OutgoingPeer
  • func NewConnection(declAddr proto.TCPAddr, address string, ver proto.Version, wavesNetwork string) (op *OutgoingPeer, err 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(p *d.Ports) (NodeConnections, error)

func (*NodeConnections) Close

func (c *NodeConnections) Close(t *testing.T)

func (*NodeConnections) SendToNodes

func (c *NodeConnections) SendToNodes(t *testing.T, m proto.Message, scala bool)

type OutgoingPeer

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

func NewConnection

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

func (*OutgoingPeer) Close

func (a *OutgoingPeer) Close() error

func (*OutgoingPeer) SendMessage

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