receive

Documentation

Index

• type Receiver
  • func NewReceiver(addr string, handle SpaceMessageHandler, log *log.Logger) *Receiver
  • func (r *Receiver) Run() func()
• type SpaceMessageHandler

Types

type Receiver

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

func NewReceiver

func NewReceiver(addr string, handle SpaceMessageHandler, log *log.Logger) *Receiver

NewReceiver creates a new receiver.

func (*Receiver) Run

func (r *Receiver) Run() func()

Run is the main runloop for the receiver. It concurrently runs an HTTP server and returns a function to stop the receiver.

type SpaceMessageHandler

type SpaceMessageHandler func(message protocol.SpaceMessage)

Callback handler for received messages.