message

Documentation

Index

• type NetMessage
  • func FromObject(p peer.Peer, data proto.Message) (NetMessage, error)
  • func New(p peer.Peer, data []byte) NetMessage
• type Pipe
  • func NewPipe(bufsize int) *Pipe
  • func (p *Pipe) ConnectTo(p2 *Pipe)

Types

type NetMessage

type NetMessage interface {
	Peer() peer.Peer
	Data() []byte
}

NetMessage is the interface for the message

func FromObject

func FromObject(p peer.Peer, data proto.Message) (NetMessage, error)

FromObject creates a message from a protobuf-marshallable message.

func New

func New(p peer.Peer, data []byte) NetMessage

New is the interface for constructing a new message.

type Pipe

type Pipe struct {
	Incoming chan NetMessage
	Outgoing chan NetMessage
}

Pipe objects represent a bi-directional message channel.

func NewPipe

func NewPipe(bufsize int) *Pipe

NewPipe constructs a pipe with channels of a given buffer size.

func (*Pipe) ConnectTo

func (p *Pipe) ConnectTo(p2 *Pipe)

ConnectTo connects this pipe to another, using a context for termination.