iot

Documentation

Index

• type IOTMessage
• type IOTWorker
  • func NewIOTWorker(ws *websocket.Conn, ctx types.LoggerContext) *IOTWorker
  • func (iot *IOTWorker) AcceptMessage(message []byte) error
  • func (iot *IOTWorker) PushMessage(message *websocket.PreparedMessage, ok bool) error
  • func (iot *IOTWorker) Run()

Types

type IOTMessage

type IOTMessage struct {
	Type string      `json:"type"`
	What string      `json:"what"`
	Data interface{} `json:"data"`
}

type IOTWorker

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

func NewIOTWorker

func NewIOTWorker(ws *websocket.Conn, ctx types.LoggerContext) *IOTWorker

func (*IOTWorker) AcceptMessage

func (iot *IOTWorker) AcceptMessage(message []byte) error

func (*IOTWorker) PushMessage

func (iot *IOTWorker) PushMessage(message *websocket.PreparedMessage, ok bool) error

func (*IOTWorker) Run

func (iot *IOTWorker) Run()