connection

Documentation

Index

• func NewOutgoing(uuid string, targetAddress string, targetPort int) (out *eventual2go.StreamController, err error)
• type Incoming
  • func NewIncoming(addr string) (i *Incoming, err error)
  • func (i *Incoming) Close()
  • func (i *Incoming) In() *eventual2go.Stream
  • func (i *Incoming) Port() (port int)
• type Message
• type Outgoing
  • func (o Outgoing) Close(eventual2go.Data) eventual2go.Data

Functions

func NewOutgoing

func NewOutgoing(uuid string, targetAddress string, targetPort int) (out *eventual2go.StreamController, err error)

Types

type Incoming

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

func NewIncoming

func NewIncoming(addr string) (i *Incoming, err error)

func (*Incoming) Close

func (i *Incoming) Close()

func (*Incoming) In

func (i *Incoming) In() *eventual2go.Stream

func (*Incoming) Port

func (i *Incoming) Port() (port int)

type Message

type Message struct {
	Iface   string
	Payload []string
}

type Outgoing

type Outgoing struct {
	*sync.Mutex
	// contains filtered or unexported fields
}

func (Outgoing) Close

func (o Outgoing) Close(eventual2go.Data) eventual2go.Data