mqtt

Documentation

Index

• type Connection
  • func NewConnection(conn websockets.Connection) *Connection
  • func (conn *Connection) Close()
  • func (conn *Connection) Read() (p []byte, err error)
  • func (conn *Connection) Write(p []byte) (err error)
• type Request
  • func (request *Request) DeviceId() (id string)
  • func (request *Request) DeviceIp() (id string)
  • func (request *Request) Validate() (err error)
• type Response
  • func Failed(err error) (resp *Response)
  • func Succeed(payload interface{}) (resp *Response)
  • func (resp *Response) Encode() (p []byte)

Types

type Connection

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

func NewConnection

func NewConnection(conn websockets.Connection) *Connection

func (*Connection) Close

func (conn *Connection) Close()

func (*Connection) Read

func (conn *Connection) Read() (p []byte, err error)

func (*Connection) Write

func (conn *Connection) Write(p []byte) (err error)

type Request

type Request struct {
	Service string          `json:"service"`
	Fn      string          `json:"fn"`
	Header  http.Header     `json:"header"`
	Payload json.RawMessage `json:"payload"`
}

func (*Request) DeviceId

func (request *Request) DeviceId() (id string)

func (*Request) DeviceIp

func (request *Request) DeviceIp() (id string)

func (*Request) Validate

func (request *Request) Validate() (err error)

type Response

type Response struct {
	Succeed bool        `json:"succeed"`
	Payload interface{} `json:"result"`
}

func Failed

func Failed(err error) (resp *Response)

func Succeed

func Succeed(payload interface{}) (resp *Response)

func (*Response) Encode

func (resp *Response) Encode() (p []byte)