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 ValidConnackError(err error) bool + func ValidQos(qos byte) bool + func ValidTopic(topic []byte) bool + func ValidVersion(v byte) bool + type ConnackCode byte + const ConnectionAccepted + const ErrBadUsernameOrPassword + const ErrIdentifierRejected + const ErrInvalidProtocolVersion + const ErrNotAuthorized + const ErrServerUnavailable + func (this ConnackCode) Desc() string + func (this ConnackCode) Error() string + func (this ConnackCode) Valid() bool + func (this ConnackCode) Value() byte + type ConnackMessage struct + func NewConnackMessage() *ConnackMessage + 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) Name() string + func (this *ConnackMessage) PacketId() uint16 + func (this *ConnackMessage) RemainingLength() int32 + func (this *ConnackMessage) ReturnCode() ConnackCode + func (this *ConnackMessage) SessionPresent() bool + func (this *ConnackMessage) SetPacketId(v uint16) + func (this *ConnackMessage) SetRemainingLength(remlen int32) error + func (this *ConnackMessage) SetReturnCode(ret ConnackCode) + func (this *ConnackMessage) SetSessionPresent(v bool) + func (this *ConnackMessage) SetType(mtype MessageType) error + func (this *ConnackMessage) Type() MessageType + func (this ConnackMessage) String() string + type ConnectMessage struct + func NewConnectMessage() *ConnectMessage + func (this *ConnectMessage) CleanSession() bool + func (this *ConnectMessage) ClientId() []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) Name() string + func (this *ConnectMessage) PacketId() uint16 + func (this *ConnectMessage) Password() []byte + func (this *ConnectMessage) PasswordFlag() bool + func (this *ConnectMessage) RemainingLength() int32 + func (this *ConnectMessage) SetCleanSession(v bool) + func (this *ConnectMessage) SetClientId(v []byte) error + func (this *ConnectMessage) SetKeepAlive(v uint16) + func (this *ConnectMessage) SetPacketId(v uint16) + func (this *ConnectMessage) SetPassword(v []byte) + func (this *ConnectMessage) SetPasswordFlag(v bool) + func (this *ConnectMessage) SetRemainingLength(remlen int32) error + 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) SetWillFlag(v bool) + func (this *ConnectMessage) SetWillMessage(v []byte) + func (this *ConnectMessage) SetWillQos(qos byte) error + func (this *ConnectMessage) SetWillRetain(v bool) + func (this *ConnectMessage) SetWillTopic(v []byte) + func (this *ConnectMessage) Type() MessageType + func (this *ConnectMessage) Username() []byte + func (this *ConnectMessage) UsernameFlag() bool + func (this *ConnectMessage) Version() byte + func (this *ConnectMessage) WillFlag() bool + func (this *ConnectMessage) WillMessage() []byte + func (this *ConnectMessage) WillQos() byte + func (this *ConnectMessage) WillRetain() bool + func (this *ConnectMessage) WillTopic() []byte + func (this ConnectMessage) String() string + type DisconnectMessage struct + func NewDisconnectMessage() *DisconnectMessage + 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) Name() string + func (this *DisconnectMessage) PacketId() uint16 + func (this *DisconnectMessage) RemainingLength() int32 + func (this *DisconnectMessage) SetPacketId(v uint16) + func (this *DisconnectMessage) SetRemainingLength(remlen int32) error + func (this *DisconnectMessage) SetType(mtype MessageType) error + func (this *DisconnectMessage) Type() MessageType + func (this DisconnectMessage) String() string + 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 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) Desc() string + func (this *PingreqMessage) Flags() byte + func (this *PingreqMessage) Len() int + func (this *PingreqMessage) Name() string + func (this *PingreqMessage) PacketId() uint16 + func (this *PingreqMessage) RemainingLength() int32 + 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) Desc() string + func (this *PingrespMessage) Flags() byte + func (this *PingrespMessage) Len() int + func (this *PingrespMessage) Name() string + func (this *PingrespMessage) PacketId() uint16 + func (this *PingrespMessage) RemainingLength() int32 + 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 PubackMessage struct + func NewPubackMessage() *PubackMessage + 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) Name() string + func (this *PubackMessage) PacketId() uint16 + func (this *PubackMessage) RemainingLength() int32 + func (this *PubackMessage) SetPacketId(v uint16) + func (this *PubackMessage) SetRemainingLength(remlen int32) error + func (this *PubackMessage) SetType(mtype MessageType) error + func (this *PubackMessage) Type() MessageType + func (this PubackMessage) String() string + type PubcompMessage struct + func NewPubcompMessage() *PubcompMessage + func (this *PubcompMessage) Desc() string + func (this *PubcompMessage) Flags() byte + func (this *PubcompMessage) Name() string + func (this *PubcompMessage) PacketId() uint16 + func (this *PubcompMessage) RemainingLength() int32 + 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) 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) Name() string + func (this *PublishMessage) PacketId() uint16 + func (this *PublishMessage) Payload() []byte + func (this *PublishMessage) QoS() byte + func (this *PublishMessage) RemainingLength() int32 + func (this *PublishMessage) Retain() bool + func (this *PublishMessage) SetDup(v bool) + func (this *PublishMessage) SetPacketId(v uint16) + func (this *PublishMessage) SetPayload(v []byte) + func (this *PublishMessage) SetQoS(v byte) error + func (this *PublishMessage) SetRemainingLength(remlen int32) error + func (this *PublishMessage) SetRetain(v bool) + func (this *PublishMessage) SetTopic(v []byte) error + func (this *PublishMessage) SetType(mtype MessageType) error + func (this *PublishMessage) Topic() []byte + func (this *PublishMessage) Type() MessageType + func (this PublishMessage) String() string + type PubrecMessage struct + func NewPubrecMessage() *PubrecMessage + func (this *PubrecMessage) Desc() string + func (this *PubrecMessage) Flags() byte + func (this *PubrecMessage) Name() string + func (this *PubrecMessage) PacketId() uint16 + func (this *PubrecMessage) RemainingLength() int32 + 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) Desc() string + func (this *PubrelMessage) Flags() byte + func (this *PubrelMessage) Name() string + func (this *PubrelMessage) PacketId() uint16 + func (this *PubrelMessage) RemainingLength() int32 + 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 SubackMessage struct + func NewSubackMessage() *SubackMessage + func (this *SubackMessage) AddReturnCode(ret byte) error + func (this *SubackMessage) AddReturnCodes(ret []byte) error + 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) Name() string + func (this *SubackMessage) PacketId() uint16 + func (this *SubackMessage) RemainingLength() int32 + func (this *SubackMessage) ReturnCodes() []byte + func (this *SubackMessage) SetPacketId(v uint16) + func (this *SubackMessage) SetRemainingLength(remlen int32) error + func (this *SubackMessage) SetType(mtype MessageType) error + func (this *SubackMessage) Type() MessageType + func (this SubackMessage) String() string + type SubscribeMessage struct + func NewSubscribeMessage() *SubscribeMessage + func (this *SubscribeMessage) AddTopic(topic []byte, qos byte) error + 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) Name() string + func (this *SubscribeMessage) PacketId() uint16 + func (this *SubscribeMessage) Qos() []byte + func (this *SubscribeMessage) RemainingLength() int32 + func (this *SubscribeMessage) RemoveTopic(topic []byte) + func (this *SubscribeMessage) SetPacketId(v uint16) + func (this *SubscribeMessage) SetRemainingLength(remlen int32) error + func (this *SubscribeMessage) SetType(mtype MessageType) error + func (this *SubscribeMessage) TopicExists(topic []byte) bool + func (this *SubscribeMessage) TopicQos(topic []byte) byte + func (this *SubscribeMessage) Topics() [][]byte + func (this *SubscribeMessage) Type() MessageType + func (this SubscribeMessage) String() string + type UnsubackMessage struct + func NewUnsubackMessage() *UnsubackMessage + func (this *UnsubackMessage) Desc() string + func (this *UnsubackMessage) Flags() byte + func (this *UnsubackMessage) Name() string + func (this *UnsubackMessage) PacketId() uint16 + func (this *UnsubackMessage) RemainingLength() int32 + 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 + type UnsubscribeMessage struct + func NewUnsubscribeMessage() *UnsubscribeMessage + func (this *UnsubscribeMessage) AddTopic(topic []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) Name() string + func (this *UnsubscribeMessage) PacketId() uint16 + func (this *UnsubscribeMessage) RemainingLength() int32 + func (this *UnsubscribeMessage) RemoveTopic(topic []byte) + func (this *UnsubscribeMessage) SetPacketId(v uint16) + 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) String() string v0.0.2-temp Aug 19, 2021
Go to main page