Versions in this module Expand all Collapse all v1 v1.5.0 Feb 25, 2023 v1.2.0 Oct 12, 2022 v1.1.0 Sep 16, 2022 v1.0.0 Sep 10, 2022 Changes in this version + const Accepted + const Auth + 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 PropAssignedClientID + const PropAuthData + const PropAuthMethod + const PropContentType + const PropCorrelationData + const PropMaximumPacketSize + const PropMaximumQOS + const PropMessageExpiry + const PropPayloadFormat + const PropReasonString + const PropReceiveMaximum + const PropRequestProblemInfo + const PropRequestResponseInfo + const PropResponseInfo + const PropResponseTopic + const PropRetainAvailable + const PropServerKeepAlive + const PropServerReference + const PropSessionExpiryInterval + const PropSharedSubAvailable + const PropSubIDAvailable + const PropSubscriptionIdentifier + const PropTopicAlias + const PropTopicAliasMaximum + const PropUser + const PropWildcardSubAvailable + const PropWillDelayInterval + 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 ErrMalformedPayload = errors.New("malformed packet: payload") + var ErrMalformedProperties = errors.New("malformed packet: properties") + 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 ErrMalformedWillProperties = errors.New("malformed packet: will properties") + 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") + var ValidProperties = map[byte]map[byte]struct + func NewReasonCodeError(c ReasonCode, message string) error + func ValidateID(p byte, i byte) bool + 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 + AllowClients []string + CleanSession bool + ClientIdentifier string + FixedHeader FixedHeader + Keepalive uint16 + PacketID uint16 + Password []byte + PasswordFlag bool + Payload []byte + Properties *Properties + ProtocolName []byte + ProtocolVersion byte + ReservedBit byte + ReturnCode byte + ReturnCodes []byte + SessionPresent bool + SubOss []SubOptions + TopicName string + Topics []string + Username []byte + UsernameFlag bool + WillFlag bool + WillMessage []byte + WillProperties *Properties + WillQos byte + WillRetain bool + WillTopic string + func (pk *Packet) ConnackDecode(buf []byte) error + func (pk *Packet) ConnackDecodeV5(buf []byte) error + func (pk *Packet) ConnackEncode(buf *bytes.Buffer) error + func (pk *Packet) ConnackEncodeV5(buf *bytes.Buffer) error + func (pk *Packet) ConnectDecode(buf []byte) error + func (pk *Packet) ConnectDecodeV5(buf []byte) error + func (pk *Packet) ConnectEncode(buf *bytes.Buffer) error + func (pk *Packet) ConnectEncodeV5(buf *bytes.Buffer) error + func (pk *Packet) ConnectValidate() (b byte, err error) + func (pk *Packet) ConnectValidateV5() (b byte, err error) + func (pk *Packet) DisconnectDecodeV5(buf []byte) error + func (pk *Packet) DisconnectEncode(buf *bytes.Buffer) error + func (pk *Packet) DisconnectEncodeV5(buf *bytes.Buffer) error + func (pk *Packet) FormatID() string + func (pk *Packet) PingreqEncode(buf *bytes.Buffer) error + func (pk *Packet) PingreqEncodeV5(buf *bytes.Buffer) error + func (pk *Packet) PingrespEncode(buf *bytes.Buffer) error + func (pk *Packet) PingrespEncodeV5(buf *bytes.Buffer) error + func (pk *Packet) PubackDecode(buf []byte) error + func (pk *Packet) PubackDecodeV5(buf []byte) error + func (pk *Packet) PubackEncode(buf *bytes.Buffer) error + func (pk *Packet) PubackEncodeV5(buf *bytes.Buffer) error + func (pk *Packet) PubcompDecode(buf []byte) error + func (pk *Packet) PubcompDecodeV5(buf []byte) error + func (pk *Packet) PubcompEncode(buf *bytes.Buffer) error + func (pk *Packet) PubcompEncodeV5(buf *bytes.Buffer) error + func (pk *Packet) PublishCopy() Packet + func (pk *Packet) PublishCopyV5() Packet + func (pk *Packet) PublishDecode(buf []byte) error + func (pk *Packet) PublishDecodeV5(buf []byte) error + func (pk *Packet) PublishEncode(buf *bytes.Buffer) error + func (pk *Packet) PublishEncodeV5(buf *bytes.Buffer) error + func (pk *Packet) PublishValidate() (byte, error) + func (pk *Packet) PublishValidateV5() (byte, error) + func (pk *Packet) PubrecDecode(buf []byte) error + func (pk *Packet) PubrecDecodeV5(buf []byte) error + func (pk *Packet) PubrecEncode(buf *bytes.Buffer) error + func (pk *Packet) PubrecEncodeV5(buf *bytes.Buffer) error + func (pk *Packet) PubrelDecode(buf []byte) error + func (pk *Packet) PubrelDecodeV5(buf []byte) error + func (pk *Packet) PubrelEncode(buf *bytes.Buffer) error + func (pk *Packet) PubrelEncodeV5(buf *bytes.Buffer) error + func (pk *Packet) SubackDecode(buf []byte) error + func (pk *Packet) SubackDecodeV5(buf []byte) error + func (pk *Packet) SubackEncode(buf *bytes.Buffer) error + func (pk *Packet) SubackEncodeV5(buf *bytes.Buffer) error + func (pk *Packet) SubscribeDecode(buf []byte) error + func (pk *Packet) SubscribeDecodeV5(buf []byte) error + func (pk *Packet) SubscribeEncode(buf *bytes.Buffer) error + func (pk *Packet) SubscribeEncodeV5(buf *bytes.Buffer) error + func (pk *Packet) SubscribeValidate() (byte, error) + func (pk *Packet) SubscribeValidateV5() (byte, error) + func (pk *Packet) UnsubackDecode(buf []byte) error + func (pk *Packet) UnsubackDecodeV5(buf []byte) error + func (pk *Packet) UnsubackEncode(buf *bytes.Buffer) error + func (pk *Packet) UnsubackEncodeV5(buf *bytes.Buffer) error + func (pk *Packet) UnsubscribeDecode(buf []byte) error + func (pk *Packet) UnsubscribeDecodeV5(buf []byte) error + func (pk *Packet) UnsubscribeEncode(buf *bytes.Buffer) error + func (pk *Packet) UnsubscribeEncodeV5(buf *bytes.Buffer) error + func (pk *Packet) UnsubscribeValidate() (byte, error) + func (pk *Packet) UnsubscribeValidateV5() (byte, error) + type Properties struct + AssignedClientID string + AuthData []byte + AuthMethod string + ContentType string + CorrelationData []byte + MaximumPacketSize *uint32 + MaximumQOS *byte + MessageExpiry *uint32 + PayloadFormat *byte + ReasonString string + ReceiveMaximum *uint16 + RequestProblemInfo *byte + RequestResponseInfo *byte + ResponseInfo string + ResponseTopic string + RetainAvailable *byte + ServerKeepAlive *uint16 + ServerReference string + SessionExpiryInterval *uint32 + SharedSubAvailable *byte + SubIDAvailable *byte + SubscriptionIdentifier *int + TopicAlias *uint16 + TopicAliasMaximum *uint16 + User []User + WildcardSubAvailable *byte + WillDelayInterval *uint32 + func (i *Properties) Pack(p byte) []byte + func (i *Properties) PackBuf(p byte) *bytes.Buffer + func (i *Properties) Unpack(r *bytes.Buffer, p byte) error + func (p *Properties) String() string + type ReasonCode byte + const AdministrativeAction + const BadAuthenticationMethod + const BadUsernameOrPassword + const Banned + const ClientIdentifierNotValid + const ConnectionRateExceeded + const ContinueAuthentication + const DisconnectWithWillMessage + const GrantedQoS0 + const GrantedQoS1 + const GrantedQoS2 + const ImplementationSpecificError + const KeepAliveTimeout + const MalformedPacket + const MaximumConnectTime + const MessageRateTooHigh + const NoMatchingSubscribers + const NoSubscriptionExisted + const NormalDisconnection + const NotAuthorized + const PacketIdentifierInUse + const PacketIdentifierNotFound + const PacketTooLarge + const PayloadFormatInvalid + const ProtocolError + const QoSNotSupported + const QuotaExceeded + const ReAuthenticate + const ReceiveMaximumExceeded + const RetainNotSupported + const ServerBusy + const ServerMoved + const ServerShuttingDown + const ServerUnavailable + const SessionTakenOver + const SharedSubscriptionsNotSupported + const SubscriptionIdentifiersNotSupported + const Success + const TopicAliasInvalid + const TopicFilterInvalid + const TopicNameInvalid + const UnspecifiedError + const UnsupportedProtocolVersion + const UseAnotherServer + const WildcardSubscriptionsNotSupported + func (c ReasonCode) IsError() bool + func (c ReasonCode) String() string + type SubOptions struct + NoLocal bool + QoS byte + RetainAsPublished bool + RetainHandling byte + type User struct + Key string + Value string
Go to main page