Versions in this module Expand all Collapse all v1 v1.0.3 Jun 3, 2021 v1.0.2 Jun 3, 2021 v1.0.1 Jun 3, 2021 Changes in this version + const Accepted + const CodeConnectBadAuthValues + const CodeConnectBadClientID + const CodeConnectBadProtocolVersion + const CodeConnectNetworkError + const CodeConnectNotAuthorised + const CodeConnectProtocolViolation + const CodeConnectServerUnavailable + const Connack + const Connect + const Disconnect + const ErrSubAckNetworkError + const Failed + const Pingreq + const Pingresp + const Puback + const Pubcomp + const Publish + const Pubrec + const Pubrel + const Reserved + const Suback + const Subscribe + const Unsuback + const Unsubscribe + var ErrInvalidFlags = errors.New("invalid flags set for packet") + var ErrMalformedClientID = errors.New("malformed packet: client id") + var ErrMalformedFlags = errors.New("malformed packet: flags") + var ErrMalformedKeepalive = errors.New("malformed packet: keepalive") + var ErrMalformedPacketID = errors.New("malformed packet: packet id") + var ErrMalformedPassword = errors.New("malformed packet: password") + var ErrMalformedProtocolName = errors.New("malformed packet: protocol name") + var ErrMalformedProtocolVersion = errors.New("malformed packet: protocol version") + var ErrMalformedQoS = errors.New("malformed packet: qos") + var ErrMalformedReturnCode = errors.New("malformed packet: return code") + var ErrMalformedSessionPresent = errors.New("malformed packet: session present") + var ErrMalformedTopic = errors.New("malformed packet: topic name") + var ErrMalformedUsername = errors.New("malformed packet: username") + var ErrMalformedWillMessage = errors.New("malformed packet: will message") + var ErrMalformedWillTopic = errors.New("malformed packet: will topic") + var ErrMissingPacketID = errors.New("missing packet id") + var ErrOffsetBoolOutOfRange = errors.New("offset bool out of range") + var ErrOffsetByteOutOfRange = errors.New("offset byte out of range") + var ErrOffsetBytesOutOfRange = errors.New("offset bytes out of range") + var ErrOffsetStrInvalidUTF8 = errors.New("offset string invalid utf8") + var ErrOffsetStrOutOfRange = errors.New("offset string out of range") + var ErrOffsetUintOutOfRange = errors.New("offset uint out of range") + var ErrOversizedLengthIndicator = errors.New("protocol violation: oversized length indicator") + var ErrProtocolViolation = errors.New("protocol violation") + var ErrSurplusPacketID = errors.New("surplus packet id") + type FixedHeader struct + Dup bool + Qos byte + Remaining int + Retain bool + Type byte + func (fh *FixedHeader) Decode(headerByte byte) error + func (fh *FixedHeader) Encode(buf *bytes.Buffer) + type Packet struct + CleanSession bool + ClientIdentifier string + FixedHeader FixedHeader + Keepalive uint16 + PacketID uint16 + Password []byte + PasswordFlag bool + Payload []byte + ProtocolName []byte + ProtocolVersion byte + Qoss []byte + ReservedBit byte + ReturnCode byte + ReturnCodes []byte + SessionPresent bool + TopicName string + Topics []string + Username []byte + UsernameFlag bool + WillFlag bool + WillMessage []byte + WillQos byte + WillRetain bool + WillTopic string + func (pk *Packet) ConnackDecode(buf []byte) error + func (pk *Packet) ConnackEncode(buf *bytes.Buffer) error + func (pk *Packet) ConnectDecode(buf []byte) error + func (pk *Packet) ConnectEncode(buf *bytes.Buffer) error + func (pk *Packet) ConnectValidate() (b byte, err error) + func (pk *Packet) DisconnectEncode(buf *bytes.Buffer) error + func (pk *Packet) PingreqEncode(buf *bytes.Buffer) error + func (pk *Packet) PingrespEncode(buf *bytes.Buffer) error + func (pk *Packet) PubackDecode(buf []byte) error + func (pk *Packet) PubackEncode(buf *bytes.Buffer) error + func (pk *Packet) PubcompDecode(buf []byte) error + func (pk *Packet) PubcompEncode(buf *bytes.Buffer) error + func (pk *Packet) PublishCopy() Packet + func (pk *Packet) PublishDecode(buf []byte) error + func (pk *Packet) PublishEncode(buf *bytes.Buffer) error + func (pk *Packet) PublishValidate() (byte, error) + func (pk *Packet) PubrecDecode(buf []byte) error + func (pk *Packet) PubrecEncode(buf *bytes.Buffer) error + func (pk *Packet) PubrelDecode(buf []byte) error + func (pk *Packet) PubrelEncode(buf *bytes.Buffer) error + func (pk *Packet) SubackDecode(buf []byte) error + func (pk *Packet) SubackEncode(buf *bytes.Buffer) error + func (pk *Packet) SubscribeDecode(buf []byte) error + func (pk *Packet) SubscribeEncode(buf *bytes.Buffer) error + func (pk *Packet) SubscribeValidate() (byte, error) + func (pk *Packet) UnsubackDecode(buf []byte) error + func (pk *Packet) UnsubackEncode(buf *bytes.Buffer) error + func (pk *Packet) UnsubscribeDecode(buf []byte) error + func (pk *Packet) UnsubscribeEncode(buf *bytes.Buffer) error + func (pk *Packet) UnsubscribeValidate() (byte, error)