Versions in this module Expand all Collapse all v0 v0.0.2 Sep 13, 2021 Changes in this version + const QosAtLeastOnce + const QosAtMostOnce + const QosExactlyOnce + const QosFailure + var SupportedVersions map[byte]string = map[byte]string + func ValidAuthReasonCode(code ReasonCode) bool + func ValidConnAckReasonCode(code ReasonCode) bool + func ValidDisconnectReasonCode(code ReasonCode) bool + func ValidPubAckReasonCode(code ReasonCode) bool + func ValidPubCompReasonCode(code ReasonCode) bool + func ValidPubRecReasonCode(code ReasonCode) bool + func ValidPubRelReasonCode(code ReasonCode) bool + func ValidQos(qos byte) bool + func ValidSubAckReasonCode(code ReasonCode) bool + func ValidTopic(topic []byte) bool + func ValidUnSubAckReasonCode(code ReasonCode) bool + func ValidVersion(v byte) bool + type AuthMessage struct + func NewAuthMessage() *AuthMessage + func (this *AuthMessage) AddUserProperty(userProperty []byte) + func (this *AuthMessage) AddUserPropertys(userProperty [][]byte) + func (this *AuthMessage) AuthData() []byte + func (this *AuthMessage) AuthMethod() []byte + func (this *AuthMessage) Decode(src []byte) (int, error) + func (this *AuthMessage) Desc() string + func (this *AuthMessage) Encode(dst []byte) (int, error) + func (this *AuthMessage) Flags() byte + func (this *AuthMessage) Len() int + func (this *AuthMessage) MtypeFlags() byte + func (this *AuthMessage) Name() string + func (this *AuthMessage) PacketId() uint16 + func (this *AuthMessage) PropertiesLen() uint32 + func (this *AuthMessage) ReasonCode() ReasonCode + func (this *AuthMessage) ReasonStr() []byte + func (this *AuthMessage) RemainingLength() int32 + func (this *AuthMessage) SetAuthData(authData []byte) + func (this *AuthMessage) SetAuthMethod(authMethod []byte) + func (this *AuthMessage) SetMtypeFlags(mtypeflags byte) + func (this *AuthMessage) SetPacketId(v uint16) + func (this *AuthMessage) SetPropertiesLen(propertiesLen uint32) + func (this *AuthMessage) SetReasonCode(reasonCode ReasonCode) + func (this *AuthMessage) SetReasonStr(reasonStr []byte) + func (this *AuthMessage) SetRemainingLength(remlen int32) error + func (this *AuthMessage) SetType(mtype MessageType) error + func (this *AuthMessage) Type() MessageType + func (this *AuthMessage) UserProperty() [][]byte + func (this AuthMessage) String() string + type ConnackMessage struct + func NewConnackMessage() *ConnackMessage + func (this *ConnackMessage) AddUserProperty(userProperty []byte) + func (this *ConnackMessage) AddUserPropertys(userProperty [][]byte) + func (this *ConnackMessage) AssignedIdentifier() []byte + func (this *ConnackMessage) AuthData() []byte + func (this *ConnackMessage) AuthMethod() []byte + func (this *ConnackMessage) Decode(src []byte) (int, error) + func (this *ConnackMessage) Desc() string + func (this *ConnackMessage) Encode(dst []byte) (int, error) + func (this *ConnackMessage) Flags() byte + func (this *ConnackMessage) Len() int + func (this *ConnackMessage) MaxPacketSize() uint32 + func (this *ConnackMessage) MaxQos() byte + func (this *ConnackMessage) MtypeFlags() byte + func (this *ConnackMessage) Name() string + func (this *ConnackMessage) PacketId() uint16 + func (this *ConnackMessage) PropertiesLen() uint32 + func (this *ConnackMessage) ReasonCode() ReasonCode + func (this *ConnackMessage) ReasonStr() []byte + func (this *ConnackMessage) ReceiveMaximum() uint16 + func (this *ConnackMessage) RemainingLength() int32 + func (this *ConnackMessage) ResponseInformation() []byte + func (this *ConnackMessage) RetainAvailable() byte + func (this *ConnackMessage) ServerKeepAlive() uint16 + func (this *ConnackMessage) ServerReference() []byte + func (this *ConnackMessage) SessionExpiryInterval() uint32 + func (this *ConnackMessage) SessionPresent() bool + func (this *ConnackMessage) SetAssignedIdentifier(assignedIdentifier []byte) + func (this *ConnackMessage) SetAuthData(authData []byte) + func (this *ConnackMessage) SetAuthMethod(authMethod []byte) + func (this *ConnackMessage) SetMaxPacketSize(maxPacketSize uint32) + func (this *ConnackMessage) SetMaxQos(maxQos byte) + func (this *ConnackMessage) SetMtypeFlags(mtypeflags byte) + func (this *ConnackMessage) SetPacketId(v uint16) + func (this *ConnackMessage) SetPropertiesLen(propertiesLen uint32) + func (this *ConnackMessage) SetReasonCode(ret ReasonCode) + func (this *ConnackMessage) SetReasonStr(reasonStr []byte) + func (this *ConnackMessage) SetReceiveMaximum(receiveMaximum uint16) + func (this *ConnackMessage) SetRemainingLength(remlen int32) error + func (this *ConnackMessage) SetResponseInformation(responseInformation []byte) + func (this *ConnackMessage) SetRetainAvailable(retainAvailable byte) + func (this *ConnackMessage) SetServerKeepAlive(serverKeepAlive uint16) + func (this *ConnackMessage) SetServerReference(serverReference []byte) + func (this *ConnackMessage) SetSessionExpiryInterval(sessionExpiryInterval uint32) + func (this *ConnackMessage) SetSessionPresent(v bool) + func (this *ConnackMessage) SetSharedSubscriptionAvailable(sharedSubscriptionAvailable byte) + func (this *ConnackMessage) SetSubscriptionIdentifierAvailable(subscriptionIdentifierAvailable byte) + func (this *ConnackMessage) SetTopicAliasMax(topicAliasMax uint16) + func (this *ConnackMessage) SetType(mtype MessageType) error + func (this *ConnackMessage) SetWildcardSubscriptionAvailable(wildcardSubscriptionAvailable byte) + func (this *ConnackMessage) SharedSubscriptionAvailable() byte + func (this *ConnackMessage) SubscriptionIdentifierAvailable() byte + func (this *ConnackMessage) TopicAliasMax() uint16 + func (this *ConnackMessage) Type() MessageType + func (this *ConnackMessage) UserProperties() [][]byte + func (this *ConnackMessage) WildcardSubscriptionAvailable() byte + func (this ConnackMessage) String() string + type ConnectMessage struct + func NewConnectMessage() *ConnectMessage + func (this *ConnectMessage) AddUserProperty(userProperty []byte) + func (this *ConnectMessage) AddUserPropertys(userProperty [][]byte) + func (this *ConnectMessage) AddWillUserProperty(willUserProperty []byte) + func (this *ConnectMessage) AddWillUserPropertys(willUserProperty [][]byte) + func (this *ConnectMessage) AuthData() []byte + func (this *ConnectMessage) AuthMethod() []byte + func (this *ConnectMessage) CleanSession() bool + func (this *ConnectMessage) CleanStart() bool + func (this *ConnectMessage) ClientId() []byte + func (this *ConnectMessage) ContentType() []byte + func (this *ConnectMessage) CorrelationData() []byte + func (this *ConnectMessage) Decode(src []byte) (int, error) + func (this *ConnectMessage) Desc() string + func (this *ConnectMessage) Encode(dst []byte) (int, error) + func (this *ConnectMessage) Flags() byte + func (this *ConnectMessage) KeepAlive() uint16 + func (this *ConnectMessage) Len() int + func (this *ConnectMessage) MaxPacketSize() uint32 + func (this *ConnectMessage) MtypeFlags() byte + func (this *ConnectMessage) Name() string + func (this *ConnectMessage) PacketId() uint16 + func (this *ConnectMessage) Password() []byte + func (this *ConnectMessage) PasswordFlag() bool + func (this *ConnectMessage) PayloadFormatIndicator() byte + func (this *ConnectMessage) PropertiesLen() uint32 + func (this *ConnectMessage) ReceiveMaximum() uint16 + func (this *ConnectMessage) RemainingLength() int32 + func (this *ConnectMessage) RequestProblemInfo() byte + func (this *ConnectMessage) RequestRespInfo() byte + func (this *ConnectMessage) ResponseTopic() []byte + func (this *ConnectMessage) SessionExpiryInterval() uint32 + func (this *ConnectMessage) SetAuthData(authData []byte) + func (this *ConnectMessage) SetAuthMethod(authMethod []byte) + func (this *ConnectMessage) SetCleanSession(v bool) + func (this *ConnectMessage) SetClientId(v []byte) error + func (this *ConnectMessage) SetContentType(contentType []byte) + func (this *ConnectMessage) SetCorrelationData(correlationData []byte) + func (this *ConnectMessage) SetKeepAlive(v uint16) + func (this *ConnectMessage) SetMaxPacketSize(maxPacketSize uint32) + func (this *ConnectMessage) SetMtypeFlags(mtypeflags byte) + func (this *ConnectMessage) SetPacketId(v uint16) + func (this *ConnectMessage) SetPassword(v []byte) + func (this *ConnectMessage) SetPasswordFlag(v bool) + func (this *ConnectMessage) SetPayloadFormatIndicator(payloadFormatIndicator byte) + func (this *ConnectMessage) SetPropertiesLen(propertiesLen uint32) + func (this *ConnectMessage) SetReceiveMaximum(receiveMaximum uint16) + func (this *ConnectMessage) SetRemainingLength(remlen int32) error + func (this *ConnectMessage) SetRequestProblemInfo(requestProblemInfo byte) + func (this *ConnectMessage) SetRequestRespInfo(requestRespInfo byte) + func (this *ConnectMessage) SetResponseTopic(responseTopic []byte) + func (this *ConnectMessage) SetSessionExpiryInterval(sessionExpiryInterval uint32) + func (this *ConnectMessage) SetTopicAliasMax(topicAliasMax uint16) + func (this *ConnectMessage) SetType(mtype MessageType) error + func (this *ConnectMessage) SetUsername(v []byte) + func (this *ConnectMessage) SetUsernameFlag(v bool) + func (this *ConnectMessage) SetVersion(v byte) error + func (this *ConnectMessage) SetWillDelayInterval(willDelayInterval uint32) + func (this *ConnectMessage) SetWillFlag(v bool) + func (this *ConnectMessage) SetWillMessage(v []byte) + func (this *ConnectMessage) SetWillMsgExpiryInterval(willMsgExpiryInterval uint32) + func (this *ConnectMessage) SetWillPropertiesLen(willPropertiesLen uint32) + func (this *ConnectMessage) SetWillQos(qos byte) error + func (this *ConnectMessage) SetWillRetain(v bool) + func (this *ConnectMessage) SetWillTopic(v []byte) + func (this *ConnectMessage) TopicAliasMax() uint16 + func (this *ConnectMessage) Type() MessageType + func (this *ConnectMessage) UserProperty() [][]byte + func (this *ConnectMessage) Username() []byte + func (this *ConnectMessage) UsernameFlag() bool + func (this *ConnectMessage) Version() byte + func (this *ConnectMessage) WillDelayInterval() uint32 + func (this *ConnectMessage) WillFlag() bool + func (this *ConnectMessage) WillMessage() []byte + func (this *ConnectMessage) WillMsgExpiryInterval() uint32 + func (this *ConnectMessage) WillPropertiesLen() uint32 + func (this *ConnectMessage) WillQos() byte + func (this *ConnectMessage) WillRetain() bool + func (this *ConnectMessage) WillTopic() []byte + func (this *ConnectMessage) WillUserProperty() [][]byte + func (this ConnectMessage) String() string + type DisconnectMessage struct + func NewDisconnectMessage() *DisconnectMessage + func (d *DisconnectMessage) String() string + func (this *DisconnectMessage) AddUserProperty(userProperty []byte) + func (this *DisconnectMessage) AddUserPropertys(userProperty [][]byte) + func (this *DisconnectMessage) Decode(src []byte) (int, error) + func (this *DisconnectMessage) Desc() string + func (this *DisconnectMessage) Encode(dst []byte) (int, error) + func (this *DisconnectMessage) Flags() byte + func (this *DisconnectMessage) Len() int + func (this *DisconnectMessage) MtypeFlags() byte + func (this *DisconnectMessage) Name() string + func (this *DisconnectMessage) PacketId() uint16 + func (this *DisconnectMessage) PropertyLen() uint32 + func (this *DisconnectMessage) ReasonCode() ReasonCode + func (this *DisconnectMessage) ReasonStr() []byte + func (this *DisconnectMessage) RemainingLength() int32 + func (this *DisconnectMessage) ServerReference() []byte + func (this *DisconnectMessage) SessionExpiryInterval() uint32 + func (this *DisconnectMessage) SetMtypeFlags(mtypeflags byte) + func (this *DisconnectMessage) SetPacketId(v uint16) + func (this *DisconnectMessage) SetPropertyLen(propertyLen uint32) + func (this *DisconnectMessage) SetReasonCode(reasonCode ReasonCode) + func (this *DisconnectMessage) SetReasonStr(reasonStr []byte) + func (this *DisconnectMessage) SetRemainingLength(remlen int32) error + func (this *DisconnectMessage) SetServerReference(serverReference []byte) + func (this *DisconnectMessage) SetSessionExpiryInterval(sessionExpiryInterval uint32) + func (this *DisconnectMessage) SetType(mtype MessageType) error + func (this *DisconnectMessage) Type() MessageType + func (this *DisconnectMessage) UserProperty() [][]byte + type Message interface + Decode func([]byte) (int, error) + Desc func() string + Encode func([]byte) (int, error) + Len func() int + Name func() string + PacketId func() uint16 + Type func() MessageType + type MessageType byte + const AUTH + const CONNACK + const CONNECT + const DISCONNECT + const PINGREQ + const PINGRESP + const PUBACK + const PUBCOMP + const PUBLISH + const PUBREC + const PUBREL + const RESERVED + const RESERVED2 + const SUBACK + const SUBSCRIBE + const UNSUBACK + const UNSUBSCRIBE + func (this MessageType) DefaultFlags() byte + func (this MessageType) Desc() string + func (this MessageType) Name() string + func (this MessageType) New() (Message, error) + func (this MessageType) String() string + func (this MessageType) Valid() bool + type PingreqMessage struct + func NewPingreqMessage() *PingreqMessage + func (this *PingreqMessage) Decode(src []byte) (int, error) + func (this *PingreqMessage) Desc() string + func (this *PingreqMessage) Encode(dst []byte) (int, error) + func (this *PingreqMessage) Flags() byte + func (this *PingreqMessage) Len() int + func (this *PingreqMessage) MtypeFlags() byte + func (this *PingreqMessage) Name() string + func (this *PingreqMessage) PacketId() uint16 + func (this *PingreqMessage) RemainingLength() int32 + func (this *PingreqMessage) SetMtypeFlags(mtypeflags byte) + func (this *PingreqMessage) SetPacketId(v uint16) + func (this *PingreqMessage) SetRemainingLength(remlen int32) error + func (this *PingreqMessage) SetType(mtype MessageType) error + func (this *PingreqMessage) Type() MessageType + func (this PingreqMessage) String() string + type PingrespMessage struct + func NewPingrespMessage() *PingrespMessage + func (this *PingrespMessage) Decode(src []byte) (int, error) + func (this *PingrespMessage) Desc() string + func (this *PingrespMessage) Encode(dst []byte) (int, error) + func (this *PingrespMessage) Flags() byte + func (this *PingrespMessage) Len() int + func (this *PingrespMessage) MtypeFlags() byte + func (this *PingrespMessage) Name() string + func (this *PingrespMessage) PacketId() uint16 + func (this *PingrespMessage) RemainingLength() int32 + func (this *PingrespMessage) SetMtypeFlags(mtypeflags byte) + func (this *PingrespMessage) SetPacketId(v uint16) + func (this *PingrespMessage) SetRemainingLength(remlen int32) error + func (this *PingrespMessage) SetType(mtype MessageType) error + func (this *PingrespMessage) Type() MessageType + func (this PingrespMessage) String() string + type PropertyCode = byte + const AssignCustomerIdentifiers + const AuthenticationData + const AuthenticationMethod + const AvailabilityOfSubscriptionIdentifiers + const ContentType + const DefiningIdentifiers + const DelayWills + const LoadFormatDescription + const MaximumLengthOfTopicAlias + const MaximumMessageLength + const MaximumQoS + const MaximumQuantityReceived + const MessageExpirationTime + const PreservePropertyAvailability + const ReasonString + const RelatedData + const RequestProblemInformation + const RequestResponseInformation + const ResponseTopic + const ServerReference + const ServerSurvivalTime + const SessionExpirationInterval + const SharedSubscriptionAvailability + const SolicitedMessage + const ThemeAlias + const UserProperty + const WildcardSubscriptionAvailability + type PubackMessage struct + func NewPubackMessage() *PubackMessage + func (this *PubackMessage) AddUserProperty(userProperty []byte) + func (this *PubackMessage) AddUserPropertys(userProperty [][]byte) + func (this *PubackMessage) Decode(src []byte) (int, error) + func (this *PubackMessage) Desc() string + func (this *PubackMessage) Encode(dst []byte) (int, error) + func (this *PubackMessage) Flags() byte + func (this *PubackMessage) Len() int + func (this *PubackMessage) MtypeFlags() byte + func (this *PubackMessage) Name() string + func (this *PubackMessage) PacketId() uint16 + func (this *PubackMessage) PropertyLen() uint32 + func (this *PubackMessage) ReasonCode() ReasonCode + func (this *PubackMessage) ReasonStr() []byte + func (this *PubackMessage) RemainingLength() int32 + func (this *PubackMessage) SetMtypeFlags(mtypeflags byte) + func (this *PubackMessage) SetPacketId(v uint16) + func (this *PubackMessage) SetPropertyLen(propertyLen uint32) + func (this *PubackMessage) SetReasonCode(reasonCode ReasonCode) + func (this *PubackMessage) SetReasonStr(reasonStr []byte) + func (this *PubackMessage) SetRemainingLength(remlen int32) error + func (this *PubackMessage) SetType(mtype MessageType) error + func (this *PubackMessage) Type() MessageType + func (this *PubackMessage) UserProperty() [][]byte + func (this PubackMessage) String() string + type PubcompMessage struct + func NewPubcompMessage() *PubcompMessage + func (this *PubcompMessage) Decode(src []byte) (int, error) + func (this *PubcompMessage) Desc() string + func (this *PubcompMessage) Flags() byte + func (this *PubcompMessage) MtypeFlags() byte + func (this *PubcompMessage) Name() string + func (this *PubcompMessage) PacketId() uint16 + func (this *PubcompMessage) RemainingLength() int32 + func (this *PubcompMessage) SetMtypeFlags(mtypeflags byte) + func (this *PubcompMessage) SetPacketId(v uint16) + func (this *PubcompMessage) SetRemainingLength(remlen int32) error + func (this *PubcompMessage) SetType(mtype MessageType) error + func (this *PubcompMessage) Type() MessageType + type PublishMessage struct + func NewPublishMessage() *PublishMessage + func (this *PublishMessage) AddUserProperty(userProperty []byte) + func (this *PublishMessage) AddUserPropertys(userProperty [][]byte) + func (this *PublishMessage) ContentType() []byte + func (this *PublishMessage) CorrelationData() []byte + func (this *PublishMessage) Decode(src []byte) (int, error) + func (this *PublishMessage) Desc() string + func (this *PublishMessage) Dup() bool + func (this *PublishMessage) Encode(dst []byte) (int, error) + func (this *PublishMessage) Flags() byte + func (this *PublishMessage) Len() int + func (this *PublishMessage) MessageExpiryInterval() uint32 + func (this *PublishMessage) MtypeFlags() byte + func (this *PublishMessage) Name() string + func (this *PublishMessage) PacketId() uint16 + func (this *PublishMessage) Payload() []byte + func (this *PublishMessage) PayloadFormatIndicator() byte + func (this *PublishMessage) PropertiesLen() uint32 + func (this *PublishMessage) QoS() byte + func (this *PublishMessage) RemainingLength() int32 + func (this *PublishMessage) ResponseTopic() []byte + func (this *PublishMessage) Retain() bool + func (this *PublishMessage) SetContentType(contentType []byte) + func (this *PublishMessage) SetCorrelationData(correlationData []byte) + func (this *PublishMessage) SetDup(v bool) + func (this *PublishMessage) SetMessageExpiryInterval(messageExpiryInterval uint32) + func (this *PublishMessage) SetMtypeFlags(mtypeflags byte) + func (this *PublishMessage) SetPacketId(v uint16) + func (this *PublishMessage) SetPayload(v []byte) + func (this *PublishMessage) SetPayloadFormatIndicator(payloadFormatIndicator byte) + func (this *PublishMessage) SetPropertiesLen(propertiesLen uint32) + func (this *PublishMessage) SetQoS(v byte) error + func (this *PublishMessage) SetRemainingLength(remlen int32) error + func (this *PublishMessage) SetResponseTopic(responseTopic []byte) + func (this *PublishMessage) SetRetain(v bool) + func (this *PublishMessage) SetSubscriptionIdentifier(subscriptionIdentifier uint32) + func (this *PublishMessage) SetTopic(v []byte) error + func (this *PublishMessage) SetTopicAlias(topicAlias uint16) + func (this *PublishMessage) SetType(mtype MessageType) error + func (this *PublishMessage) SubscriptionIdentifier() uint32 + func (this *PublishMessage) Topic() []byte + func (this *PublishMessage) TopicAlias() uint16 + func (this *PublishMessage) Type() MessageType + func (this *PublishMessage) UserProperty() [][]byte + func (this PublishMessage) String() string + type PubrecMessage struct + func NewPubrecMessage() *PubrecMessage + func (this *PubrecMessage) Decode(src []byte) (int, error) + func (this *PubrecMessage) Desc() string + func (this *PubrecMessage) Flags() byte + func (this *PubrecMessage) MtypeFlags() byte + func (this *PubrecMessage) Name() string + func (this *PubrecMessage) PacketId() uint16 + func (this *PubrecMessage) RemainingLength() int32 + func (this *PubrecMessage) SetMtypeFlags(mtypeflags byte) + func (this *PubrecMessage) SetPacketId(v uint16) + func (this *PubrecMessage) SetRemainingLength(remlen int32) error + func (this *PubrecMessage) SetType(mtype MessageType) error + func (this *PubrecMessage) Type() MessageType + type PubrelMessage struct + func NewPubrelMessage() *PubrelMessage + func (this *PubrelMessage) Decode(src []byte) (int, error) + func (this *PubrelMessage) Desc() string + func (this *PubrelMessage) Flags() byte + func (this *PubrelMessage) MtypeFlags() byte + func (this *PubrelMessage) Name() string + func (this *PubrelMessage) PacketId() uint16 + func (this *PubrelMessage) RemainingLength() int32 + func (this *PubrelMessage) SetMtypeFlags(mtypeflags byte) + func (this *PubrelMessage) SetPacketId(v uint16) + func (this *PubrelMessage) SetRemainingLength(remlen int32) error + func (this *PubrelMessage) SetType(mtype MessageType) error + func (this *PubrelMessage) Type() MessageType + type ReasonCode uint8 + const BeyondQuota + const ContinueAuthentication + const CustomerIdentifierInvalid + const DisconnectionIncludesWill + const ExceededConnectionRateLimit + const Forbid + const ImplementError + const InvalidAuthenticationMethod + const InvalidLoadFormat + const InvalidMessage + const InvalidTopicAlias + const InvalidTopicFilter + const InvalidTopicName + const KeepAliveTimeout + const ManagementBehavior + const MaximumConnectionTime + const MaximumNumberReceivedExceeded + const MessageTooLong + const NoExistSubscription + const NoMatchSubscription + const NormalDisconnected + const PacketIdentifierInvalid + const PacketIdentifierIsOccupied + const ProtocolError + const Qos0 + const Qos1 + const Qos2 + const ReAuthentication + const ServerBeingShutDown + const ServerHasMoved + const ServerUnavailable + const ServiceBusy + const SessionTakeover + const Success + const TooManyMessages + const UnAuthorized + const UnSupportedProtocolVersion + const UnspecifiedError + const UnsupportedQoSLevel + const UnsupportedRetention + const UnsupportedSharedSubscriptions + const UnsupportedSubscriptionIdentifiers + const UnsupportedWildcardSubscriptions + const UseOtherServers + const UserNameOrPasswordIsIncorrect + func (this ReasonCode) Desc() string + func (this ReasonCode) Error() string + func (this ReasonCode) String() string + func (this ReasonCode) Valid() bool + func (this ReasonCode) Value() byte + type RetainHandling byte + const CanSendRetain + const NoExistSubSendRetain + const NoSendRetain + type SubackMessage struct + func NewSubackMessage() *SubackMessage + func (this *SubackMessage) AddReasonCode(ret byte) error + func (this *SubackMessage) AddReasonCodes(ret []byte) error + func (this *SubackMessage) AddUserProperty(userProperty []byte) + func (this *SubackMessage) AddUserPropertys(userProperty [][]byte) + func (this *SubackMessage) Decode(src []byte) (int, error) + func (this *SubackMessage) Desc() string + func (this *SubackMessage) Encode(dst []byte) (int, error) + func (this *SubackMessage) Flags() byte + func (this *SubackMessage) Len() int + func (this *SubackMessage) MtypeFlags() byte + func (this *SubackMessage) Name() string + func (this *SubackMessage) PacketId() uint16 + func (this *SubackMessage) PropertiesLen() uint32 + func (this *SubackMessage) ReasonCodes() []byte + func (this *SubackMessage) ReasonStr() []byte + func (this *SubackMessage) RemainingLength() int32 + func (this *SubackMessage) SetMtypeFlags(mtypeflags byte) + func (this *SubackMessage) SetPacketId(v uint16) + func (this *SubackMessage) SetPropertiesLen(propertiesLen uint32) + func (this *SubackMessage) SetReasonStr(reasonStr []byte) + func (this *SubackMessage) SetRemainingLength(remlen int32) error + func (this *SubackMessage) SetType(mtype MessageType) error + func (this *SubackMessage) Type() MessageType + func (this *SubackMessage) UserProperty() [][]byte + func (this SubackMessage) String() string + type SubscribeMessage struct + func NewSubscribeMessage() *SubscribeMessage + func (this *SubscribeMessage) AddTopic(topic []byte, qos byte) error + func (this *SubscribeMessage) AddTopicAll(topic []byte, qos byte, local, retainAsPub bool, retainHandling byte) error + func (this *SubscribeMessage) AddUserProperty(userProperty []byte) + func (this *SubscribeMessage) AddUserPropertys(userProperty [][]byte) + func (this *SubscribeMessage) Decode(src []byte) (int, error) + func (this *SubscribeMessage) Desc() string + func (this *SubscribeMessage) Encode(dst []byte) (int, error) + func (this *SubscribeMessage) Flags() byte + func (this *SubscribeMessage) Len() int + func (this *SubscribeMessage) MtypeFlags() byte + func (this *SubscribeMessage) Name() string + func (this *SubscribeMessage) PacketId() uint16 + func (this *SubscribeMessage) PropertiesLen() uint32 + func (this *SubscribeMessage) Qos() []byte + func (this *SubscribeMessage) RemainingLength() int32 + func (this *SubscribeMessage) RemoveTopic(topic []byte) + func (this *SubscribeMessage) SetMtypeFlags(mtypeflags byte) + func (this *SubscribeMessage) SetPacketId(v uint16) + func (this *SubscribeMessage) SetPropertiesLen(propertiesLen uint32) + func (this *SubscribeMessage) SetRemainingLength(remlen int32) error + func (this *SubscribeMessage) SetSubscriptionIdentifier(subscriptionIdentifier uint32) + func (this *SubscribeMessage) SetTopicLocal(topic []byte, local bool) + func (this *SubscribeMessage) SetTopicRetainAsPublished(topic []byte, rap bool) + func (this *SubscribeMessage) SetTopicRetainHandling(topic []byte, hand RetainHandling) + func (this *SubscribeMessage) SetType(mtype MessageType) error + func (this *SubscribeMessage) SubscriptionIdentifier() uint32 + func (this *SubscribeMessage) TopicExists(topic []byte) bool + func (this *SubscribeMessage) TopicLocal(topic []byte) bool + func (this *SubscribeMessage) TopicQos(topic []byte) byte + func (this *SubscribeMessage) TopicRetainAsPublished(topic []byte) bool + func (this *SubscribeMessage) TopicRetainHandling(topic []byte) RetainHandling + func (this *SubscribeMessage) Topics() [][]byte + func (this *SubscribeMessage) Type() MessageType + func (this *SubscribeMessage) UserProperty() [][]byte + func (this SubscribeMessage) String() string + type UnsubackMessage struct + func NewUnsubackMessage() *UnsubackMessage + func (this *UnsubackMessage) AddUserProperty(userProperty []byte) + func (this *UnsubackMessage) AddUserPropertys(userProperty [][]byte) + func (this *UnsubackMessage) Decode(src []byte) (int, error) + func (this *UnsubackMessage) Desc() string + func (this *UnsubackMessage) Encode(dst []byte) (int, error) + func (this *UnsubackMessage) Flags() byte + func (this *UnsubackMessage) Len() int + func (this *UnsubackMessage) MtypeFlags() byte + func (this *UnsubackMessage) Name() string + func (this *UnsubackMessage) PacketId() uint16 + func (this *UnsubackMessage) RemainingLength() int32 + func (this *UnsubackMessage) SetMtypeFlags(mtypeflags byte) + func (this *UnsubackMessage) SetPacketId(v uint16) + func (this *UnsubackMessage) SetRemainingLength(remlen int32) error + func (this *UnsubackMessage) SetType(mtype MessageType) error + func (this *UnsubackMessage) Type() MessageType + func (this UnsubackMessage) String() string + func (u *UnsubackMessage) AddReasonCode(reasonCode byte) + func (u *UnsubackMessage) AddReasonCodes(reasonCodes []byte) + func (u *UnsubackMessage) PropertyLen() uint32 + func (u *UnsubackMessage) ReasonCodes() []byte + func (u *UnsubackMessage) ReasonStr() []byte + func (u *UnsubackMessage) SetPropertyLen(propertyLen uint32) + func (u *UnsubackMessage) SetReasonStr(reasonStr []byte) + func (u *UnsubackMessage) UserProperty() [][]byte + type UnsubscribeMessage struct + func NewUnsubscribeMessage() *UnsubscribeMessage + func (this *UnsubscribeMessage) AddTopic(topic []byte) + func (this *UnsubscribeMessage) AddUserProperty(userProperty []byte) + func (this *UnsubscribeMessage) AddUserPropertys(userProperty [][]byte) + func (this *UnsubscribeMessage) Decode(src []byte) (int, error) + func (this *UnsubscribeMessage) Desc() string + func (this *UnsubscribeMessage) Encode(dst []byte) (int, error) + func (this *UnsubscribeMessage) Flags() byte + func (this *UnsubscribeMessage) Len() int + func (this *UnsubscribeMessage) MtypeFlags() byte + func (this *UnsubscribeMessage) Name() string + func (this *UnsubscribeMessage) PacketId() uint16 + func (this *UnsubscribeMessage) PropertyLen() uint32 + func (this *UnsubscribeMessage) RemainingLength() int32 + func (this *UnsubscribeMessage) RemoveTopic(topic []byte) + func (this *UnsubscribeMessage) SetMtypeFlags(mtypeflags byte) + func (this *UnsubscribeMessage) SetPacketId(v uint16) + func (this *UnsubscribeMessage) SetPropertyLen(propertyLen uint32) + func (this *UnsubscribeMessage) SetRemainingLength(remlen int32) error + func (this *UnsubscribeMessage) SetType(mtype MessageType) error + func (this *UnsubscribeMessage) TopicExists(topic []byte) bool + func (this *UnsubscribeMessage) Topics() [][]byte + func (this *UnsubscribeMessage) Type() MessageType + func (this *UnsubscribeMessage) UserProperty() [][]byte + func (this UnsubscribeMessage) String() string v0.0.2-temp Aug 19, 2021