README
¶
mqttconn
A sane MQTT client for go based on paho.mqtt.golang that implements net.PacketConn
(and therefore net.Conn, io.ReadWriteCloser, io.ReadWriter)
A quick peek
// connect to hivemq public broker with no password, with a default topic test
conn, _ := mqttconn.DialMQTT("mqtt://broker.hivemq.com/test")
// you can also do urls like "mqtt://username:password@server:port/topic"
// or you can just omit to topic like "mqtt://broker.hivemq.com", in which
// case Write and Read are not going to work before calling SetDefaultTopic
// and Subscribe
// publish to topic test
conn.Write([]byte("hello world!"))
// publish to another topic
conn.WriteTo([]byte("hello world!"), mqttconn.TopicAddr("anothertopic"))
// read conn
readBuffer := make([]byte, 4096)
n, addr, err := conn.ReadFrom(readBuffer)
// addr.String() is the topic from which the message is received.
// readBuffer[:n] is the received message
Documentation
¶
Index ¶
- type MQTTConn
- func (conn *MQTTConn) Close() error
- func (conn *MQTTConn) LocalAddr() net.Addr
- func (conn *MQTTConn) Read(p []byte) (n int, err error)
- func (conn *MQTTConn) ReadFrom(p []byte) (n int, addr net.Addr, err error)
- func (conn *MQTTConn) RemoteAddr() net.Addr
- func (conn *MQTTConn) SetDeadline(t time.Time) error
- func (conn *MQTTConn) SetDefaultQoS(qos int)
- func (conn *MQTTConn) SetDefaultTopic(topic string)
- func (conn *MQTTConn) SetReadDeadline(t time.Time) error
- func (conn *MQTTConn) SetWriteDeadline(t time.Time) error
- func (conn *MQTTConn) Subscribe(topic string, qos int) error
- func (conn *MQTTConn) Write(p []byte) (n int, err error)
- func (conn *MQTTConn) WriteTo(b []byte, addr net.Addr) (int, error)
- type TopicAddr
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MQTTConn ¶
MQTTConn wraps around mqtt and provides net.PacketConn functionality
func CreateMQTTConn ¶
CreateMQTTConn wraps around an existing mqtt.Client
func DialMQTT ¶
DialMQTT acts like DialUDP or DialTCP takes in a url like mqtt://username:password@server:port/topic
func (*MQTTConn) RemoteAddr ¶
RemoteAddr implements net.PacketConn.RemoteAddr
func (*MQTTConn) SetDeadline ¶
SetDeadline implements net.PacketConn.SetDeadline
func (*MQTTConn) SetDefaultQoS ¶
SetDefaultQoS sets default QOS of a MQTTConn, which Write uses
func (*MQTTConn) SetDefaultTopic ¶
SetDefaultTopic sets default topic of a MQTTConn, which Write uses
func (*MQTTConn) SetReadDeadline ¶
SetReadDeadline implements net.PacketConn.SetReadDeadline
func (*MQTTConn) SetWriteDeadline ¶
SetWriteDeadline implements net.PacketConn.SetWriteDeadline
Source Files