util

Documentation

Index

• func DebugMQTT(tag string, c net.Conn, msg mqtt.Message)
• func DebugMQTTMsg(tag string, c proxy.ProxyConn, msg mqtt.Message)
• func IsMqttDisconnect(msg mqtt.Message) bool
• type MqttTcpMessageReader
  • func CreateMqttTcpMessageReader(tcpconn net.Conn, readTimeout time.Duration) *MqttTcpMessageReader
  • func (m *MqttTcpMessageReader) ReadMqttMessages()

Functions

func DebugMQTT

func DebugMQTT(tag string, c net.Conn, msg mqtt.Message)

func DebugMQTTMsg

func DebugMQTTMsg(tag string, c proxy.ProxyConn, msg mqtt.Message)

func IsMqttDisconnect

func IsMqttDisconnect(msg mqtt.Message) bool

Types

type MqttTcpMessageReader

type MqttTcpMessageReader struct {
	Tcpconn     net.Conn
	InMsgs      chan mqtt.Message
	InErrors    chan error
	ReadTimeout time.Duration
}

func CreateMqttTcpMessageReader

func CreateMqttTcpMessageReader(tcpconn net.Conn, readTimeout time.Duration) *MqttTcpMessageReader

func (*MqttTcpMessageReader) ReadMqttMessages

func (m *MqttTcpMessageReader) ReadMqttMessages()