Versions in this module Expand all Collapse all v0 v0.5.0 May 13, 2023 v0.4.0 Apr 15, 2023 v0.3.0 Apr 11, 2023 v0.2.0 Dec 29, 2022 v0.1.1 Nov 6, 2022 v0.1.0 Nov 1, 2022 v0.0.2 Aug 23, 2022 v0.0.1 Jun 7, 2020 Changes in this version + const AT_LEAST_ONCE + const AT_MOST_ONCE + const AUTH + const Accepted + const CONNACK + const CONNECT + const DISCONNECT + const EXACTLY_ONCE + const FAILURE + const MQTT + const MQTT_3_1_1 + const MQTT_5 + const PINGREQ + const PINGRESP + const PUBACK + const PUBCOMP + const PUBLISH + const PUBREC + const PUBREL + const RefusedBadUserNameOrPassword + const RefusedIdentifierRejected + const RefusedNotAuthorized + const RefusedServerUnavailable + const RefusedUnacceptableProtocolVersion + const SUBACK + const SUBSCRIBE + const UNSUBACK + const UNSUBSCRIBE + var MqttMessageTypeNames = map[byte]string + var MqttQoSNames = map[byte]string + func NewConnAckError(returnCode byte, text string) error + type ConnackPacket struct + ReturnCode byte + SessionPresent bool + func (p *ConnackPacket) Name() string + func (p *ConnackPacket) String() string + func (p *ConnackPacket) Type() byte + func (p *ConnackPacket) Unpack(b io.Reader) error + func (p *ConnackPacket) Write(w io.Writer) (err error) + type ConnectAckError struct + func (e *ConnectAckError) Error() string + func (e *ConnectAckError) ReturnCode() byte + type ConnectPacket struct + CleanSession bool + ClientIdentifier string + HasPassword bool + HasUsername bool + KeepAliveSeconds uint16 + Password []byte + ProtocolLevel byte + ProtocolName string + ReservedBit bool + Username string + WillFlag bool + WillMessage []byte + WillQos byte + WillRetain bool + WillTopic string + func (p *ConnectPacket) Name() string + func (p *ConnectPacket) String() string + func (p *ConnectPacket) Type() byte + func (p *ConnectPacket) Unpack(r io.Reader) (err error) + func (p *ConnectPacket) Write(w io.Writer) (err error) + type ControlPacket interface + Name func() string + String func() string + Type func() byte + Unpack func(io.Reader) error + Write func(io.Writer) error + func NewControlPacket(packetType byte) ControlPacket + func NewControlPacketWithHeader(fh FixedHeader) (ControlPacket, error) + func ReadPacket(r io.Reader) (ControlPacket, error) + type DisconnectPacket struct + func (p *DisconnectPacket) Name() string + func (p *DisconnectPacket) String() string + func (p *DisconnectPacket) Type() byte + func (p *DisconnectPacket) Unpack(_ io.Reader) error + func (p *DisconnectPacket) Write(w io.Writer) (err error) + type FixedHeader struct + Dup bool + MessageType byte + Qos byte + RemainingLength int + Retain bool + func (fh *FixedHeader) MessageName() string + func (fh FixedHeader) String() string + type PingreqPacket struct + func (p *PingreqPacket) Name() string + func (p *PingreqPacket) String() string + func (p *PingreqPacket) Type() byte + func (p *PingreqPacket) Unpack(_ io.Reader) error + func (p *PingreqPacket) Write(w io.Writer) (err error) + type PingrespPacket struct + func (p *PingrespPacket) Name() string + func (p *PingrespPacket) String() string + func (p *PingrespPacket) Type() byte + func (p *PingrespPacket) Unpack(_ io.Reader) error + func (p *PingrespPacket) Write(w io.Writer) (err error) + type PubackPacket struct + MessageID uint16 + func (p *PubackPacket) Name() string + func (p *PubackPacket) String() string + func (p *PubackPacket) Type() byte + func (p *PubackPacket) Unpack(b io.Reader) (err error) + func (p *PubackPacket) Write(w io.Writer) (err error) + type PubcompPacket struct + MessageID uint16 + func (p *PubcompPacket) Name() string + func (p *PubcompPacket) String() string + func (p *PubcompPacket) Type() byte + func (p *PubcompPacket) Unpack(b io.Reader) (err error) + func (p *PubcompPacket) Write(w io.Writer) (err error) + type PublishPacket struct + Message []byte + MessageID uint16 + TopicName string + func (c *PublishPacket) Name() string + func (p *PublishPacket) String() string + func (p *PublishPacket) Type() byte + func (p *PublishPacket) Unpack(b io.Reader) (err error) + func (p *PublishPacket) Write(w io.Writer) (err error) + type PubrecPacket struct + MessageID uint16 + func (p *PubrecPacket) Name() string + func (p *PubrecPacket) String() string + func (p *PubrecPacket) Type() byte + func (p *PubrecPacket) Unpack(b io.Reader) (err error) + func (p *PubrecPacket) Write(w io.Writer) (err error) + type PubrelPacket struct + MessageID uint16 + func (p *PubrelPacket) Name() string + func (p *PubrelPacket) String() string + func (p *PubrelPacket) Type() byte + func (p *PubrelPacket) Unpack(b io.Reader) (err error) + func (p *PubrelPacket) Write(w io.Writer) (err error) + type SubackPacket struct + MessageID uint16 + ReturnCodes []byte + func (p *SubackPacket) Name() string + func (p *SubackPacket) String() string + func (p *SubackPacket) Type() byte + func (p *SubackPacket) Unpack(b io.Reader) (err error) + func (p *SubackPacket) Write(w io.Writer) (err error) + type SubscribePacket struct + MessageID uint16 + TopicSubscriptions []TopicSubscription + func (p *SubscribePacket) Name() string + func (p *SubscribePacket) String() string + func (p *SubscribePacket) Type() byte + func (p *SubscribePacket) Unpack(b io.Reader) (err error) + func (p *SubscribePacket) Write(w io.Writer) (err error) + type TopicSubscription struct + Qos byte + TopicFilter string + func (ts *TopicSubscription) String() string + type UnsubackPacket struct + MessageID uint16 + func (p *UnsubackPacket) Name() string + func (p *UnsubackPacket) String() string + func (p *UnsubackPacket) Type() byte + func (p *UnsubackPacket) Unpack(b io.Reader) (err error) + func (p *UnsubackPacket) Write(w io.Writer) (err error) + type UnsubscribePacket struct + MessageID uint16 + TopicFilters []string + func (p *UnsubscribePacket) Name() string + func (p *UnsubscribePacket) String() string + func (p *UnsubscribePacket) Type() byte + func (p *UnsubscribePacket) Unpack(b io.Reader) (err error) + func (p *UnsubscribePacket) Write(w io.Writer) (err error)
Go to main page